You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: plugins/node/instrumentation-kafkajs/README.md
+24-1Lines changed: 24 additions & 1 deletion
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -53,7 +53,30 @@ You can set the following:
53
53
54
54
This package uses `@opentelemetry/semantic-conventions` version `1.30+`, which implements Semantic Convention [Version 1.30.0](https://github.com/open-telemetry/semantic-conventions/blob/v1.30.0/docs/README.md)
55
55
56
-
Attributes collected:
56
+
### Spans Emitted
57
+
58
+
| KafkaJS Object | Action | Span Kind | Span Name | Operation Type / Name |
**[1]`process <topic-name>`:** In the context of `eachBatch`, this span will be emitted for each message in the batch but the timing (start, end, duration) will reflect the timing of the batch.
65
+
66
+
### Metrics Emitted
67
+
68
+
| KafkaJS Object | Metric Name | Short Description |
| Consumer |`messaging.process.duration`| Duration of processing operation. [1]|
71
+
| Consumer |`messaging.client.consumed.messages`| Number of messages that were delivered to the application. |
72
+
| Consumer and Producer |`messaging.client.operation.duration`| Number of messages that were delivered to the application. |
73
+
| Producer |`messaging.client.sent.messages`| Number of messages producer attempted to send to the broker. |
74
+
75
+
**[1]`messaging.process.duration`:** In the context of `eachBatch`, this metric will be emitted once for each message but the value reflects the duration of the entire batch.
76
+
77
+
### Attributes Collected
78
+
79
+
These attributes are added to both spans and metrics, where possible.
0 commit comments