diff --git a/docs/instrumentation-list.yaml b/docs/instrumentation-list.yaml index 3dc6950f0b8d..8f9518479d23 100644 --- a/docs/instrumentation-list.yaml +++ b/docs/instrumentation-list.yaml @@ -6571,6 +6571,14 @@ libraries: type: LONG - name: url.full type: STRING + jfinal: + - name: jfinal-3.2 + source_path: instrumentation/jfinal-3.2 + scope: + name: io.opentelemetry.jfinal-3.2 + target_versions: + javaagent: + - com.jfinal:jfinal:[3.2,) jms: - name: jms-1.1 display_name: JMS (Java Message Service) @@ -6931,123 +6939,19 @@ libraries: type: boolean default: false telemetry: - - when: default - spans: - - span_kind: CONSUMER - attributes: - - name: messaging.batch.message_count - type: LONG - - name: messaging.client_id - type: STRING - - name: messaging.destination.name - type: STRING - - name: messaging.destination.partition.id - type: STRING - - name: messaging.kafka.consumer.group - type: STRING - - name: messaging.kafka.message.key - type: STRING - - name: messaging.kafka.message.offset - type: LONG - - name: messaging.kafka.message.tombstone - type: BOOLEAN - - name: messaging.message.body.size - type: LONG - - name: messaging.operation - type: STRING - - name: messaging.system - type: STRING - - span_kind: PRODUCER - attributes: - - name: messaging.client_id - type: STRING - - name: messaging.destination.name - type: STRING - - name: messaging.destination.partition.id - type: STRING - - name: messaging.kafka.message.key - type: STRING - - name: messaging.kafka.message.offset - type: LONG - - name: messaging.kafka.message.tombstone - type: BOOLEAN - - name: messaging.operation - type: STRING - - name: messaging.system - type: STRING - - when: otel.instrumentation.kafka.experimental-span-attributes=true - spans: - - span_kind: CONSUMER - attributes: - - name: kafka.record.queue_time_ms - type: LONG - - name: messaging.batch.message_count - type: LONG - - name: messaging.client_id - type: STRING - - name: messaging.destination.name - type: STRING - - name: messaging.destination.partition.id - type: STRING - - name: messaging.kafka.consumer.group - type: STRING - - name: messaging.kafka.message.key - type: STRING - - name: messaging.kafka.message.offset - type: LONG - - name: messaging.kafka.message.tombstone - type: BOOLEAN - - name: messaging.message.body.size - type: LONG - - name: messaging.operation - type: STRING - - name: messaging.system - type: STRING - - span_kind: PRODUCER - attributes: - - name: messaging.client_id - type: STRING - - name: messaging.destination.name - type: STRING - - name: messaging.destination.partition.id - type: STRING - - name: messaging.kafka.message.key - type: STRING - - name: messaging.kafka.message.offset - type: LONG - - name: messaging.kafka.message.tombstone - type: BOOLEAN - - name: messaging.operation - type: STRING - - name: messaging.system - type: STRING - - name: kafka-clients-2.6 - display_name: Apache Kafka Client - description: This standalone instrumentation enables messaging spans for Kafka - producers and consumers, and collects internal Kafka client metrics. - semantic_conventions: - - MESSAGING_SPANS - library_link: https://kafka.apache.org/ - source_path: instrumentation/kafka/kafka-clients/kafka-clients-2.6 - scope: - name: io.opentelemetry.kafka-clients-2.6 - target_versions: - library: - - org.apache.kafka:kafka-clients:2.6.0 - telemetry: - when: default metrics: - name: kafka.consumer.assigned_partitions description: The number of partitions currently assigned to this consumer type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.bytes_consumed_rate description: The average number of bytes consumed per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7056,7 +6960,7 @@ libraries: - name: kafka.consumer.bytes_consumed_total description: The total number of bytes consumed type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7065,133 +6969,147 @@ libraries: - name: kafka.consumer.commit_latency_avg description: The average time taken for a commit request type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.commit_latency_max description: The max time taken for a commit request type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.commit_rate description: The number of commit calls per second type: DOUBLE_GAUGE - unit: null + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.commit_sync_time_ns_total + description: The total time the consumer has spent in commitSync in nanoseconds + type: DOUBLE_SUM + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.commit_total description: The total number of commit calls type: DOUBLE_SUM - unit: null + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.committed_time_ns_total + description: The total time the consumer has spent in committed in nanoseconds + type: DOUBLE_SUM + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.connection_close_rate description: The number of connections closed per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.connection_close_total description: The total number of connections closed type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.connection_count description: The current number of active connections. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.connection_creation_rate description: The number of new connections established per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.connection_creation_total description: The total number of new connections established type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.failed_authentication_rate description: The number of connections with failed authentication per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.failed_authentication_total description: The total number of connections with failed authentication type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.failed_reauthentication_rate description: The number of failed re-authentication of connections per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.failed_reauthentication_total description: The total number of failed re-authentication of connections type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.failed_rebalance_rate_per_hour description: The number of failed rebalance events per hour type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.failed_rebalance_total description: The total number of failed rebalance events type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.fetch_latency_avg description: The average time taken for a fetch request. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.fetch_latency_max description: The max time taken for any fetch request. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.fetch_rate description: The number of fetch requests per second. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.fetch_size_avg description: The average number of bytes fetched per request type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7200,7 +7118,7 @@ libraries: - name: kafka.consumer.fetch_size_max description: The maximum number of bytes fetched per request type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7209,42 +7127,42 @@ libraries: - name: kafka.consumer.fetch_throttle_time_avg description: The average throttle time in ms type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.fetch_throttle_time_max description: The maximum throttle time in ms type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.fetch_total description: The total number of fetch requests. type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.heartbeat_rate description: The number of heartbeats per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.heartbeat_total description: The total number of heartbeats type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.incoming_byte_rate description: The number of bytes read off all sockets per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7253,7 +7171,7 @@ libraries: - name: kafka.consumer.incoming_byte_total description: The total number of bytes read off all sockets type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7262,21 +7180,28 @@ libraries: - name: kafka.consumer.io_ratio description: The fraction of time the I/O thread spent doing I/O type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.io_time_ns_avg description: The average length of time for I/O per select call in nanoseconds. type: DOUBLE_GAUGE - unit: null + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.io_time_ns_total + description: The total time the I/O thread spent doing I/O + type: DOUBLE_SUM + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.io_wait_ratio description: The fraction of time the I/O thread spent waiting type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7284,49 +7209,42 @@ libraries: description: The average length of time the I/O thread spent waiting for a socket ready for reads or writes in nanoseconds. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - - name: kafka.consumer.io_waittime_total + - name: kafka.consumer.io_wait_time_ns_total description: The total time the I/O thread spent waiting type: DOUBLE_SUM - unit: null - attributes: - - name: client-id - type: STRING - - name: kafka.consumer.iotime_total - description: The total time the I/O thread spent doing I/O - type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.join_rate description: The number of group joins per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.join_time_avg description: The average time taken for a group rejoin type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.join_time_max description: The max time taken for a group rejoin type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.join_total description: The total number of group joins type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7334,21 +7252,21 @@ libraries: description: The number of seconds since the last coordinator heartbeat was sent type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.last_poll_seconds_ago description: The number of seconds since the last poll() invocation. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.last_rebalance_seconds_ago description: The number of seconds since the last successful rebalance event type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7356,7 +7274,7 @@ libraries: description: The number of network operations (reads or writes) on all connections per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7364,14 +7282,14 @@ libraries: description: The total number of network operations (reads or writes) on all connections type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.outgoing_byte_rate description: The number of outgoing bytes sent to all servers per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7380,7 +7298,7 @@ libraries: - name: kafka.consumer.outgoing_byte_total description: The total number of outgoing bytes sent to all servers type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7390,7 +7308,7 @@ libraries: description: The average time taken for a partition-assigned rebalance listener callback type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7398,7 +7316,7 @@ libraries: description: The max time taken for a partition-assigned rebalance listener callback type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7406,7 +7324,7 @@ libraries: description: The average fraction of time the consumer's poll() is idle as opposed to waiting for the user code to process records. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7414,7 +7332,7 @@ libraries: description: The average time taken for a group to complete a successful rebalance, which may be composed of several failed re-trials until it succeeded type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7422,7 +7340,7 @@ libraries: description: The max time taken for a group to complete a successful rebalance, which may be composed of several failed re-trials until it succeeded type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7430,7 +7348,7 @@ libraries: description: The total number of milliseconds this consumer has spent in successful rebalances since creation type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7438,7 +7356,7 @@ libraries: description: The number of successful rebalance events per hour, each event is composed of several failed re-trials until it succeeded type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7446,14 +7364,14 @@ libraries: description: The total number of successful rebalance events, each event is composed of several failed re-trials until it succeeded type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.records_consumed_rate description: The average number of records consumed per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7462,16 +7380,19 @@ libraries: - name: kafka.consumer.records_consumed_total description: The total number of records consumed type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: topic type: STRING - name: kafka.consumer.records_lag - description: The latest lag of the partition + description: 'The latest lag of the partition. Note: For topic names with + periods (.), an additional metric with underscores is emitted. However, + the periods replaced metric is deprecated. Please use the metric with actual + topic name instead.' type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7480,9 +7401,12 @@ libraries: - name: topic type: STRING - name: kafka.consumer.records_lag_avg - description: The average lag of the partition + description: 'The average lag of the partition. Note: For topic names with + periods (.), an additional metric with underscores is emitted. However, + the periods replaced metric is deprecated. Please use the metric with actual + topic name instead.' type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7491,10 +7415,11 @@ libraries: - name: topic type: STRING - name: kafka.consumer.records_lag_max - description: The maximum lag in terms of number of records for any partition - in this window + description: 'The maximum lag in terms of number of records for any partition + in this window. NOTE: This is based on current offset and not committed + offset' type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7503,9 +7428,12 @@ libraries: - name: topic type: STRING - name: kafka.consumer.records_lead - description: The latest lead of the partition + description: 'The latest lead of the partition. Note: For topic names with + periods (.), an additional metric with underscores is emitted. However, + the periods replaced metric is deprecated. Please use the metric with actual + topic name instead.' type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7514,9 +7442,12 @@ libraries: - name: topic type: STRING - name: kafka.consumer.records_lead_avg - description: The average lead of the partition + description: 'The average lead of the partition. Note: For topic names with + periods (.), an additional metric with underscores is emitted. However, + the periods replaced metric is deprecated. Please use the metric with actual + topic name instead.' type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7528,7 +7459,7 @@ libraries: description: The minimum lead in terms of number of records for any partition in this window type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7539,16 +7470,34 @@ libraries: - name: kafka.consumer.records_per_request_avg description: The average number of records in each request type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: topic type: STRING + - name: kafka.consumer.request_latency_avg + description: '' + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.request_latency_max + description: '' + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING - name: kafka.consumer.request_rate description: The number of requests sent per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7557,7 +7506,7 @@ libraries: - name: kafka.consumer.request_size_avg description: The average size of requests sent. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7566,7 +7515,7 @@ libraries: - name: kafka.consumer.request_size_max description: The maximum size of any request sent. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7575,7 +7524,7 @@ libraries: - name: kafka.consumer.request_total description: The total number of requests sent type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7584,7 +7533,7 @@ libraries: - name: kafka.consumer.response_rate description: The number of responses received per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7593,7 +7542,7 @@ libraries: - name: kafka.consumer.response_total description: The total number of responses received type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7603,7 +7552,7 @@ libraries: description: The number of times the I/O layer checked for new I/O to perform per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7611,7 +7560,7 @@ libraries: description: The total number of times the I/O layer checked for new I/O to perform type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7619,7 +7568,7 @@ libraries: description: The total number of connections with successful authentication where the client does not support re-authentication type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7627,14 +7576,14 @@ libraries: description: The number of connections with successful authentication per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.successful_authentication_total description: The total number of connections with successful authentication type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7642,84 +7591,84 @@ libraries: description: The number of successful re-authentication of connections per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.successful_reauthentication_total description: The total number of successful re-authentication of connections type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.sync_rate description: The number of group syncs per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.sync_time_avg description: The average time taken for a group sync type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.sync_time_max description: The max time taken for a group sync type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.sync_total description: The total number of group syncs type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.time_between_poll_avg - description: The average delay between invocations of poll(). + description: The average delay between invocations of poll() in milliseconds. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.consumer.time_between_poll_max - description: The max delay between invocations of poll(). + description: The max delay between invocations of poll() in milliseconds. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.batch_size_avg description: The average number of bytes sent per partition per-request. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.batch_size_max description: The max number of bytes sent per partition per-request. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.batch_split_rate description: The average number of batch splits per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.batch_split_total description: The total number of batch splits type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7727,7 +7676,7 @@ libraries: description: The total amount of buffer memory that is not being used (either unallocated or in the free list). type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7735,7 +7684,7 @@ libraries: description: The average per-second number of record sends that are dropped due to buffer exhaustion type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7743,7 +7692,7 @@ libraries: description: The total number of record sends that are dropped due to buffer exhaustion type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7751,28 +7700,28 @@ libraries: description: The maximum amount of buffer memory the client can use (whether or not it is currently used). type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.bufferpool_wait_ratio description: The fraction of time an appender waits for space allocation. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - - name: kafka.producer.bufferpool_wait_time_total - description: The total time an appender waits for space allocation. + - name: kafka.producer.bufferpool_wait_time_ns_total + description: The total time in nanoseconds an appender waits for space allocation. type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.byte_rate description: The average number of bytes sent per second for a topic. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7781,95 +7730,105 @@ libraries: - name: kafka.producer.byte_total description: The total number of bytes sent for a topic. type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: topic type: STRING - name: kafka.producer.compression_rate - description: The average compression rate of record batches for a topic. + description: The average compression rate of record batches for a topic, defined + as the average ratio of the compressed batch size over the uncompressed + size. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: topic type: STRING - name: kafka.producer.compression_rate_avg - description: The average compression rate of record batches. + description: The average compression rate of record batches, defined as the + average ratio of the compressed batch size over the uncompressed size. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.connection_close_rate description: The number of connections closed per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.connection_close_total description: The total number of connections closed type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.connection_count description: The current number of active connections. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.connection_creation_rate description: The number of new connections established per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.connection_creation_total description: The total number of new connections established type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.failed_authentication_rate description: The number of connections with failed authentication per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.failed_authentication_total description: The total number of connections with failed authentication type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.failed_reauthentication_rate description: The number of failed re-authentication of connections per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.failed_reauthentication_total description: The total number of failed re-authentication of connections type: DOUBLE_SUM - unit: null + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.flush_time_ns_total + description: Total time producer has spent in flush in nanoseconds. + type: DOUBLE_SUM + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.incoming_byte_rate description: The number of bytes read off all sockets per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7878,7 +7837,7 @@ libraries: - name: kafka.producer.incoming_byte_total description: The total number of bytes read off all sockets type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7887,21 +7846,28 @@ libraries: - name: kafka.producer.io_ratio description: The fraction of time the I/O thread spent doing I/O type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.io_time_ns_avg description: The average length of time for I/O per select call in nanoseconds. type: DOUBLE_GAUGE - unit: null + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.io_time_ns_total + description: The total time the I/O thread spent doing I/O + type: DOUBLE_SUM + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.io_wait_ratio description: The fraction of time the I/O thread spent waiting type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7909,28 +7875,28 @@ libraries: description: The average length of time the I/O thread spent waiting for a socket ready for reads or writes in nanoseconds. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - - name: kafka.producer.io_waittime_total + - name: kafka.producer.io_wait_time_ns_total description: The total time the I/O thread spent waiting type: DOUBLE_SUM - unit: null - attributes: - - name: client-id - type: STRING - - name: kafka.producer.iotime_total - description: The total time the I/O thread spent doing I/O - type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.metadata_age description: The age in seconds of the current producer metadata being used. type: DOUBLE_GAUGE - unit: null + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.metadata_wait_time_ns_total + description: Total time producer has spent waiting on topic metadata in nanoseconds. + type: DOUBLE_SUM + unit: '' attributes: - name: client-id type: STRING @@ -7938,7 +7904,7 @@ libraries: description: The number of network operations (reads or writes) on all connections per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7946,14 +7912,14 @@ libraries: description: The total number of network operations (reads or writes) on all connections type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.outgoing_byte_rate description: The number of outgoing bytes sent to all servers per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7962,7 +7928,7 @@ libraries: - name: kafka.producer.outgoing_byte_total description: The total number of outgoing bytes sent to all servers type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7971,14 +7937,14 @@ libraries: - name: kafka.producer.produce_throttle_time_avg description: The average time in ms a request was throttled by a broker type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.produce_throttle_time_max description: The maximum time in ms a request was throttled by a broker type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7986,7 +7952,7 @@ libraries: description: The average per-second number of record sends that resulted in errors type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -7995,7 +7961,7 @@ libraries: - name: kafka.producer.record_error_total description: The total number of record sends that resulted in errors type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8004,21 +7970,21 @@ libraries: - name: kafka.producer.record_queue_time_avg description: The average time in ms record batches spent in the send buffer. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.record_queue_time_max description: The maximum time in ms record batches spent in the send buffer. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.record_retry_rate description: The average per-second number of retried record sends type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8027,7 +7993,7 @@ libraries: - name: kafka.producer.record_retry_total description: The total number of retried record sends type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8036,7 +8002,7 @@ libraries: - name: kafka.producer.record_send_rate description: The average number of records sent per second. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8045,7 +8011,7 @@ libraries: - name: kafka.producer.record_send_total description: The total number of records sent. type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8054,28 +8020,28 @@ libraries: - name: kafka.producer.record_size_avg description: The average record size type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.record_size_max description: The maximum record size type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.records_per_request_avg description: The average number of records per request. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.request_latency_avg description: The average request latency in ms type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8084,7 +8050,7 @@ libraries: - name: kafka.producer.request_latency_max description: The maximum request latency in ms type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8093,7 +8059,7 @@ libraries: - name: kafka.producer.request_rate description: The number of requests sent per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8102,7 +8068,7 @@ libraries: - name: kafka.producer.request_size_avg description: The average size of requests sent. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8111,7 +8077,7 @@ libraries: - name: kafka.producer.request_size_max description: The maximum size of any request sent. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8120,7 +8086,7 @@ libraries: - name: kafka.producer.request_total description: The total number of requests sent type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8129,14 +8095,14 @@ libraries: - name: kafka.producer.requests_in_flight description: The current number of in-flight requests awaiting a response. type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.response_rate description: The number of responses received per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8145,7 +8111,7 @@ libraries: - name: kafka.producer.response_total description: The total number of responses received type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8155,7 +8121,7 @@ libraries: description: The number of times the I/O layer checked for new I/O to perform per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8163,7 +8129,7 @@ libraries: description: The total number of times the I/O layer checked for new I/O to perform type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8171,7 +8137,7 @@ libraries: description: The total number of connections with successful authentication where the client does not support re-authentication type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8179,14 +8145,14 @@ libraries: description: The number of connections with successful authentication per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.successful_authentication_total description: The total number of connections with successful authentication type: DOUBLE_SUM - unit: null + unit: '' attributes: - name: client-id type: STRING @@ -8194,14 +8160,57 @@ libraries: description: The number of successful re-authentication of connections per second type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING - name: kafka.producer.successful_reauthentication_total description: The total number of successful re-authentication of connections type: DOUBLE_SUM - unit: null + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.txn_abort_time_ns_total + description: Total time producer has spent in abortTransaction in nanoseconds. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.txn_begin_time_ns_total + description: Total time producer has spent in beginTransaction in nanoseconds. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.txn_commit_time_ns_total + description: Total time producer has spent in commitTransaction in nanoseconds. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.txn_init_time_ns_total + description: Total time producer has spent in initTransactions in nanoseconds. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.txn_prepare_time_ns_total + description: Total time producer has spent in prepareTransaction in nanoseconds. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.txn_send_offsets_time_ns_total + description: Total time producer has spent in sendOffsetsToTransaction in + nanoseconds. + type: DOUBLE_SUM + unit: '' attributes: - name: client-id type: STRING @@ -8209,15 +8218,13 @@ libraries: description: The number of user threads blocked waiting for buffer memory to enqueue their records type: DOUBLE_GAUGE - unit: null + unit: '' attributes: - name: client-id type: STRING spans: - span_kind: CONSUMER attributes: - - name: kafka.record.queue_time_ms - type: LONG - name: messaging.batch.message_count type: LONG - name: messaging.client_id @@ -8228,8 +8235,12 @@ libraries: type: STRING - name: messaging.kafka.consumer.group type: STRING + - name: messaging.kafka.message.key + type: STRING - name: messaging.kafka.message.offset type: LONG + - name: messaging.kafka.message.tombstone + type: BOOLEAN - name: messaging.message.body.size type: LONG - name: messaging.operation @@ -8244,51 +8255,2612 @@ libraries: type: STRING - name: messaging.destination.partition.id type: STRING + - name: messaging.kafka.message.key + type: STRING - name: messaging.kafka.message.offset type: LONG + - name: messaging.kafka.message.tombstone + type: BOOLEAN - name: messaging.operation type: STRING - name: messaging.system type: STRING - - name: kafka-connect-2.6 - display_name: Apache Kafka Connect - description: This instrumentation enables messaging spans for Kafka Connect sink - tasks. - semantic_conventions: - - MESSAGING_SPANS - library_link: https://kafka.apache.org/documentation/#connect - source_path: instrumentation/kafka/kafka-connect-2.6 - scope: - name: io.opentelemetry.kafka-connect-2.6 - target_versions: - javaagent: - - org.apache.kafka:connect-api:[2.6.0,) - telemetry: - - when: default - spans: - - span_kind: CONSUMER + - when: otel.instrumentation.kafka.experimental-span-attributes=true + metrics: + - name: kafka.consumer.assigned_partitions + description: The number of partitions currently assigned to this consumer + type: DOUBLE_GAUGE + unit: '' attributes: - - name: messaging.batch.message_count - type: LONG - - name: messaging.destination.name + - name: client-id type: STRING - - name: messaging.operation + - name: kafka.consumer.bytes_consumed_rate + description: The average number of bytes consumed per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id type: STRING - - name: messaging.system + - name: topic type: STRING - - name: thread.id - type: LONG - - name: thread.name + - name: kafka.consumer.bytes_consumed_total + description: The total number of bytes consumed + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id type: STRING - - name: kafka-streams-0.11 - display_name: Apache Kafka Streams - description: This instrumentation enables messaging spans for Kafka Streams processing. - semantic_conventions: - - MESSAGING_SPANS - library_link: https://kafka.apache.org/documentation/streams/ - source_path: instrumentation/kafka/kafka-streams-0.11 - scope: - name: io.opentelemetry.kafka-streams-0.11 + - name: topic + type: STRING + - name: kafka.consumer.commit_latency_avg + description: The average time taken for a commit request + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.commit_latency_max + description: The max time taken for a commit request + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.commit_rate + description: The number of commit calls per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.commit_sync_time_ns_total + description: The total time the consumer has spent in commitSync in nanoseconds + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.commit_total + description: The total number of commit calls + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.committed_time_ns_total + description: The total time the consumer has spent in committed in nanoseconds + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.connection_close_rate + description: The number of connections closed per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.connection_close_total + description: The total number of connections closed + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.connection_count + description: The current number of active connections. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.connection_creation_rate + description: The number of new connections established per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.connection_creation_total + description: The total number of new connections established + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.failed_authentication_rate + description: The number of connections with failed authentication per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.failed_authentication_total + description: The total number of connections with failed authentication + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.failed_reauthentication_rate + description: The number of failed re-authentication of connections per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.failed_reauthentication_total + description: The total number of failed re-authentication of connections + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.failed_rebalance_rate_per_hour + description: The number of failed rebalance events per hour + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.failed_rebalance_total + description: The total number of failed rebalance events + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.fetch_latency_avg + description: The average time taken for a fetch request. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.fetch_latency_max + description: The max time taken for any fetch request. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.fetch_rate + description: The number of fetch requests per second. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.fetch_size_avg + description: The average number of bytes fetched per request + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.fetch_size_max + description: The maximum number of bytes fetched per request + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.fetch_throttle_time_avg + description: The average throttle time in ms + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.fetch_throttle_time_max + description: The maximum throttle time in ms + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.fetch_total + description: The total number of fetch requests. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.heartbeat_rate + description: The number of heartbeats per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.heartbeat_total + description: The total number of heartbeats + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.incoming_byte_rate + description: The number of bytes read off all sockets per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.incoming_byte_total + description: The total number of bytes read off all sockets + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.io_ratio + description: The fraction of time the I/O thread spent doing I/O + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.io_time_ns_avg + description: The average length of time for I/O per select call in nanoseconds. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.io_time_ns_total + description: The total time the I/O thread spent doing I/O + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.io_wait_ratio + description: The fraction of time the I/O thread spent waiting + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.io_wait_time_ns_avg + description: The average length of time the I/O thread spent waiting for a + socket ready for reads or writes in nanoseconds. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.io_wait_time_ns_total + description: The total time the I/O thread spent waiting + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.join_rate + description: The number of group joins per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.join_time_avg + description: The average time taken for a group rejoin + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.join_time_max + description: The max time taken for a group rejoin + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.join_total + description: The total number of group joins + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.last_heartbeat_seconds_ago + description: The number of seconds since the last coordinator heartbeat was + sent + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.last_poll_seconds_ago + description: The number of seconds since the last poll() invocation. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.last_rebalance_seconds_ago + description: The number of seconds since the last successful rebalance event + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.network_io_rate + description: The number of network operations (reads or writes) on all connections + per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.network_io_total + description: The total number of network operations (reads or writes) on all + connections + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.outgoing_byte_rate + description: The number of outgoing bytes sent to all servers per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.outgoing_byte_total + description: The total number of outgoing bytes sent to all servers + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.partition_assigned_latency_avg + description: The average time taken for a partition-assigned rebalance listener + callback + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.partition_assigned_latency_max + description: The max time taken for a partition-assigned rebalance listener + callback + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.poll_idle_ratio_avg + description: The average fraction of time the consumer's poll() is idle as + opposed to waiting for the user code to process records. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.rebalance_latency_avg + description: The average time taken for a group to complete a successful rebalance, + which may be composed of several failed re-trials until it succeeded + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.rebalance_latency_max + description: The max time taken for a group to complete a successful rebalance, + which may be composed of several failed re-trials until it succeeded + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.rebalance_latency_total + description: The total number of milliseconds this consumer has spent in successful + rebalances since creation + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.rebalance_rate_per_hour + description: The number of successful rebalance events per hour, each event + is composed of several failed re-trials until it succeeded + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.rebalance_total + description: The total number of successful rebalance events, each event is + composed of several failed re-trials until it succeeded + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.records_consumed_rate + description: The average number of records consumed per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_consumed_total + description: The total number of records consumed + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_lag + description: 'The latest lag of the partition. Note: For topic names with + periods (.), an additional metric with underscores is emitted. However, + the periods replaced metric is deprecated. Please use the metric with actual + topic name instead.' + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: partition + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_lag_avg + description: 'The average lag of the partition. Note: For topic names with + periods (.), an additional metric with underscores is emitted. However, + the periods replaced metric is deprecated. Please use the metric with actual + topic name instead.' + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: partition + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_lag_max + description: 'The maximum lag in terms of number of records for any partition + in this window. NOTE: This is based on current offset and not committed + offset' + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: partition + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_lead + description: 'The latest lead of the partition. Note: For topic names with + periods (.), an additional metric with underscores is emitted. However, + the periods replaced metric is deprecated. Please use the metric with actual + topic name instead.' + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: partition + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_lead_avg + description: 'The average lead of the partition. Note: For topic names with + periods (.), an additional metric with underscores is emitted. However, + the periods replaced metric is deprecated. Please use the metric with actual + topic name instead.' + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: partition + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_lead_min + description: The minimum lead in terms of number of records for any partition + in this window + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: partition + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_per_request_avg + description: The average number of records in each request + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.request_latency_avg + description: '' + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.request_latency_max + description: '' + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.request_rate + description: The number of requests sent per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.request_size_avg + description: The average size of requests sent. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.request_size_max + description: The maximum size of any request sent. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.request_total + description: The total number of requests sent + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.response_rate + description: The number of responses received per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.response_total + description: The total number of responses received + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.select_rate + description: The number of times the I/O layer checked for new I/O to perform + per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.select_total + description: The total number of times the I/O layer checked for new I/O to + perform + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.successful_authentication_no_reauth_total + description: The total number of connections with successful authentication + where the client does not support re-authentication + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.successful_authentication_rate + description: The number of connections with successful authentication per + second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.successful_authentication_total + description: The total number of connections with successful authentication + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.successful_reauthentication_rate + description: The number of successful re-authentication of connections per + second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.successful_reauthentication_total + description: The total number of successful re-authentication of connections + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.sync_rate + description: The number of group syncs per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.sync_time_avg + description: The average time taken for a group sync + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.sync_time_max + description: The max time taken for a group sync + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.sync_total + description: The total number of group syncs + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.time_between_poll_avg + description: The average delay between invocations of poll() in milliseconds. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.time_between_poll_max + description: The max delay between invocations of poll() in milliseconds. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.batch_size_avg + description: The average number of bytes sent per partition per-request. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.batch_size_max + description: The max number of bytes sent per partition per-request. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.batch_split_rate + description: The average number of batch splits per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.batch_split_total + description: The total number of batch splits + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.buffer_available_bytes + description: The total amount of buffer memory that is not being used (either + unallocated or in the free list). + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.buffer_exhausted_rate + description: The average per-second number of record sends that are dropped + due to buffer exhaustion + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.buffer_exhausted_total + description: The total number of record sends that are dropped due to buffer + exhaustion + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.buffer_total_bytes + description: The maximum amount of buffer memory the client can use (whether + or not it is currently used). + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.bufferpool_wait_ratio + description: The fraction of time an appender waits for space allocation. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.bufferpool_wait_time_ns_total + description: The total time in nanoseconds an appender waits for space allocation. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.byte_rate + description: The average number of bytes sent per second for a topic. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.byte_total + description: The total number of bytes sent for a topic. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.compression_rate + description: The average compression rate of record batches for a topic, defined + as the average ratio of the compressed batch size over the uncompressed + size. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.compression_rate_avg + description: The average compression rate of record batches, defined as the + average ratio of the compressed batch size over the uncompressed size. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.connection_close_rate + description: The number of connections closed per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.connection_close_total + description: The total number of connections closed + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.connection_count + description: The current number of active connections. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.connection_creation_rate + description: The number of new connections established per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.connection_creation_total + description: The total number of new connections established + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.failed_authentication_rate + description: The number of connections with failed authentication per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.failed_authentication_total + description: The total number of connections with failed authentication + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.failed_reauthentication_rate + description: The number of failed re-authentication of connections per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.failed_reauthentication_total + description: The total number of failed re-authentication of connections + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.flush_time_ns_total + description: Total time producer has spent in flush in nanoseconds. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.incoming_byte_rate + description: The number of bytes read off all sockets per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.incoming_byte_total + description: The total number of bytes read off all sockets + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.io_ratio + description: The fraction of time the I/O thread spent doing I/O + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.io_time_ns_avg + description: The average length of time for I/O per select call in nanoseconds. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.io_time_ns_total + description: The total time the I/O thread spent doing I/O + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.io_wait_ratio + description: The fraction of time the I/O thread spent waiting + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.io_wait_time_ns_avg + description: The average length of time the I/O thread spent waiting for a + socket ready for reads or writes in nanoseconds. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.io_wait_time_ns_total + description: The total time the I/O thread spent waiting + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.metadata_age + description: The age in seconds of the current producer metadata being used. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.metadata_wait_time_ns_total + description: Total time producer has spent waiting on topic metadata in nanoseconds. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.network_io_rate + description: The number of network operations (reads or writes) on all connections + per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.network_io_total + description: The total number of network operations (reads or writes) on all + connections + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.outgoing_byte_rate + description: The number of outgoing bytes sent to all servers per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.outgoing_byte_total + description: The total number of outgoing bytes sent to all servers + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.produce_throttle_time_avg + description: The average time in ms a request was throttled by a broker + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.produce_throttle_time_max + description: The maximum time in ms a request was throttled by a broker + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.record_error_rate + description: The average per-second number of record sends that resulted in + errors + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.record_error_total + description: The total number of record sends that resulted in errors + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.record_queue_time_avg + description: The average time in ms record batches spent in the send buffer. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.record_queue_time_max + description: The maximum time in ms record batches spent in the send buffer. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.record_retry_rate + description: The average per-second number of retried record sends + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.record_retry_total + description: The total number of retried record sends + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.record_send_rate + description: The average number of records sent per second. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.record_send_total + description: The total number of records sent. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.record_size_avg + description: The average record size + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.record_size_max + description: The maximum record size + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.records_per_request_avg + description: The average number of records per request. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.request_latency_avg + description: The average request latency in ms + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.request_latency_max + description: The maximum request latency in ms + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.request_rate + description: The number of requests sent per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.request_size_avg + description: The average size of requests sent. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.request_size_max + description: The maximum size of any request sent. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.request_total + description: The total number of requests sent + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.requests_in_flight + description: The current number of in-flight requests awaiting a response. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.response_rate + description: The number of responses received per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.response_total + description: The total number of responses received + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.select_rate + description: The number of times the I/O layer checked for new I/O to perform + per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.select_total + description: The total number of times the I/O layer checked for new I/O to + perform + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.successful_authentication_no_reauth_total + description: The total number of connections with successful authentication + where the client does not support re-authentication + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.successful_authentication_rate + description: The number of connections with successful authentication per + second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.successful_authentication_total + description: The total number of connections with successful authentication + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.successful_reauthentication_rate + description: The number of successful re-authentication of connections per + second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.successful_reauthentication_total + description: The total number of successful re-authentication of connections + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.txn_abort_time_ns_total + description: Total time producer has spent in abortTransaction in nanoseconds. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.txn_begin_time_ns_total + description: Total time producer has spent in beginTransaction in nanoseconds. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.txn_commit_time_ns_total + description: Total time producer has spent in commitTransaction in nanoseconds. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.txn_init_time_ns_total + description: Total time producer has spent in initTransactions in nanoseconds. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.txn_prepare_time_ns_total + description: Total time producer has spent in prepareTransaction in nanoseconds. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.txn_send_offsets_time_ns_total + description: Total time producer has spent in sendOffsetsToTransaction in + nanoseconds. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.waiting_threads + description: The number of user threads blocked waiting for buffer memory + to enqueue their records + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + spans: + - span_kind: CONSUMER + attributes: + - name: kafka.record.queue_time_ms + type: LONG + - name: messaging.batch.message_count + type: LONG + - name: messaging.client_id + type: STRING + - name: messaging.destination.name + type: STRING + - name: messaging.destination.partition.id + type: STRING + - name: messaging.kafka.consumer.group + type: STRING + - name: messaging.kafka.message.key + type: STRING + - name: messaging.kafka.message.offset + type: LONG + - name: messaging.kafka.message.tombstone + type: BOOLEAN + - name: messaging.message.body.size + type: LONG + - name: messaging.operation + type: STRING + - name: messaging.system + type: STRING + - span_kind: PRODUCER + attributes: + - name: messaging.client_id + type: STRING + - name: messaging.destination.name + type: STRING + - name: messaging.destination.partition.id + type: STRING + - name: messaging.kafka.message.key + type: STRING + - name: messaging.kafka.message.offset + type: LONG + - name: messaging.kafka.message.tombstone + type: BOOLEAN + - name: messaging.operation + type: STRING + - name: messaging.system + type: STRING + - name: kafka-clients-2.6 + display_name: Apache Kafka Client + description: This standalone instrumentation enables messaging spans for Kafka + producers and consumers, and collects internal Kafka client metrics. + semantic_conventions: + - MESSAGING_SPANS + library_link: https://kafka.apache.org/ + source_path: instrumentation/kafka/kafka-clients/kafka-clients-2.6 + scope: + name: io.opentelemetry.kafka-clients-2.6 + target_versions: + library: + - org.apache.kafka:kafka-clients:2.6.0 + telemetry: + - when: default + metrics: + - name: kafka.consumer.assigned_partitions + description: The number of partitions currently assigned to this consumer + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.bytes_consumed_rate + description: The average number of bytes consumed per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.bytes_consumed_total + description: The total number of bytes consumed + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.commit_latency_avg + description: The average time taken for a commit request + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.commit_latency_max + description: The max time taken for a commit request + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.commit_rate + description: The number of commit calls per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.commit_total + description: The total number of commit calls + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.connection_close_rate + description: The number of connections closed per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.connection_close_total + description: The total number of connections closed + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.connection_count + description: The current number of active connections. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.connection_creation_rate + description: The number of new connections established per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.connection_creation_total + description: The total number of new connections established + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.failed_authentication_rate + description: The number of connections with failed authentication per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.failed_authentication_total + description: The total number of connections with failed authentication + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.failed_reauthentication_rate + description: The number of failed re-authentication of connections per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.failed_reauthentication_total + description: The total number of failed re-authentication of connections + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.failed_rebalance_rate_per_hour + description: The number of failed rebalance events per hour + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.failed_rebalance_total + description: The total number of failed rebalance events + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.fetch_latency_avg + description: The average time taken for a fetch request. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.fetch_latency_max + description: The max time taken for any fetch request. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.fetch_rate + description: The number of fetch requests per second. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.fetch_size_avg + description: The average number of bytes fetched per request + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.fetch_size_max + description: The maximum number of bytes fetched per request + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.fetch_throttle_time_avg + description: The average throttle time in ms + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.fetch_throttle_time_max + description: The maximum throttle time in ms + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.fetch_total + description: The total number of fetch requests. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.heartbeat_rate + description: The number of heartbeats per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.heartbeat_total + description: The total number of heartbeats + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.incoming_byte_rate + description: The number of bytes read off all sockets per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.incoming_byte_total + description: The total number of bytes read off all sockets + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.io_ratio + description: The fraction of time the I/O thread spent doing I/O + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.io_time_ns_avg + description: The average length of time for I/O per select call in nanoseconds. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.io_wait_ratio + description: The fraction of time the I/O thread spent waiting + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.io_wait_time_ns_avg + description: The average length of time the I/O thread spent waiting for a + socket ready for reads or writes in nanoseconds. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.io_waittime_total + description: The total time the I/O thread spent waiting + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.iotime_total + description: The total time the I/O thread spent doing I/O + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.join_rate + description: The number of group joins per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.join_time_avg + description: The average time taken for a group rejoin + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.join_time_max + description: The max time taken for a group rejoin + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.join_total + description: The total number of group joins + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.last_heartbeat_seconds_ago + description: The number of seconds since the last coordinator heartbeat was + sent + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.last_poll_seconds_ago + description: The number of seconds since the last poll() invocation. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.last_rebalance_seconds_ago + description: The number of seconds since the last successful rebalance event + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.network_io_rate + description: The number of network operations (reads or writes) on all connections + per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.network_io_total + description: The total number of network operations (reads or writes) on all + connections + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.outgoing_byte_rate + description: The number of outgoing bytes sent to all servers per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.outgoing_byte_total + description: The total number of outgoing bytes sent to all servers + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.partition_assigned_latency_avg + description: The average time taken for a partition-assigned rebalance listener + callback + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.partition_assigned_latency_max + description: The max time taken for a partition-assigned rebalance listener + callback + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.poll_idle_ratio_avg + description: The average fraction of time the consumer's poll() is idle as + opposed to waiting for the user code to process records. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.rebalance_latency_avg + description: The average time taken for a group to complete a successful rebalance, + which may be composed of several failed re-trials until it succeeded + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.rebalance_latency_max + description: The max time taken for a group to complete a successful rebalance, + which may be composed of several failed re-trials until it succeeded + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.rebalance_latency_total + description: The total number of milliseconds this consumer has spent in successful + rebalances since creation + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.rebalance_rate_per_hour + description: The number of successful rebalance events per hour, each event + is composed of several failed re-trials until it succeeded + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.rebalance_total + description: The total number of successful rebalance events, each event is + composed of several failed re-trials until it succeeded + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.records_consumed_rate + description: The average number of records consumed per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_consumed_total + description: The total number of records consumed + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_lag + description: The latest lag of the partition + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: partition + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_lag_avg + description: The average lag of the partition + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: partition + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_lag_max + description: The maximum lag in terms of number of records for any partition + in this window + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: partition + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_lead + description: The latest lead of the partition + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: partition + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_lead_avg + description: The average lead of the partition + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: partition + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_lead_min + description: The minimum lead in terms of number of records for any partition + in this window + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: partition + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.records_per_request_avg + description: The average number of records in each request + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.consumer.request_rate + description: The number of requests sent per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.request_size_avg + description: The average size of requests sent. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.request_size_max + description: The maximum size of any request sent. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.request_total + description: The total number of requests sent + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.response_rate + description: The number of responses received per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.response_total + description: The total number of responses received + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.consumer.select_rate + description: The number of times the I/O layer checked for new I/O to perform + per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.select_total + description: The total number of times the I/O layer checked for new I/O to + perform + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.successful_authentication_no_reauth_total + description: The total number of connections with successful authentication + where the client does not support re-authentication + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.successful_authentication_rate + description: The number of connections with successful authentication per + second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.successful_authentication_total + description: The total number of connections with successful authentication + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.successful_reauthentication_rate + description: The number of successful re-authentication of connections per + second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.successful_reauthentication_total + description: The total number of successful re-authentication of connections + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.sync_rate + description: The number of group syncs per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.sync_time_avg + description: The average time taken for a group sync + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.sync_time_max + description: The max time taken for a group sync + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.sync_total + description: The total number of group syncs + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.time_between_poll_avg + description: The average delay between invocations of poll(). + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.consumer.time_between_poll_max + description: The max delay between invocations of poll(). + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.batch_size_avg + description: The average number of bytes sent per partition per-request. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.batch_size_max + description: The max number of bytes sent per partition per-request. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.batch_split_rate + description: The average number of batch splits per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.batch_split_total + description: The total number of batch splits + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.buffer_available_bytes + description: The total amount of buffer memory that is not being used (either + unallocated or in the free list). + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.buffer_exhausted_rate + description: The average per-second number of record sends that are dropped + due to buffer exhaustion + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.buffer_exhausted_total + description: The total number of record sends that are dropped due to buffer + exhaustion + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.buffer_total_bytes + description: The maximum amount of buffer memory the client can use (whether + or not it is currently used). + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.bufferpool_wait_ratio + description: The fraction of time an appender waits for space allocation. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.bufferpool_wait_time_total + description: The total time an appender waits for space allocation. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.byte_rate + description: The average number of bytes sent per second for a topic. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.byte_total + description: The total number of bytes sent for a topic. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.compression_rate + description: The average compression rate of record batches for a topic. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.compression_rate_avg + description: The average compression rate of record batches. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.connection_close_rate + description: The number of connections closed per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.connection_close_total + description: The total number of connections closed + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.connection_count + description: The current number of active connections. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.connection_creation_rate + description: The number of new connections established per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.connection_creation_total + description: The total number of new connections established + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.failed_authentication_rate + description: The number of connections with failed authentication per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.failed_authentication_total + description: The total number of connections with failed authentication + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.failed_reauthentication_rate + description: The number of failed re-authentication of connections per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.failed_reauthentication_total + description: The total number of failed re-authentication of connections + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.incoming_byte_rate + description: The number of bytes read off all sockets per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.incoming_byte_total + description: The total number of bytes read off all sockets + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.io_ratio + description: The fraction of time the I/O thread spent doing I/O + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.io_time_ns_avg + description: The average length of time for I/O per select call in nanoseconds. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.io_wait_ratio + description: The fraction of time the I/O thread spent waiting + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.io_wait_time_ns_avg + description: The average length of time the I/O thread spent waiting for a + socket ready for reads or writes in nanoseconds. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.io_waittime_total + description: The total time the I/O thread spent waiting + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.iotime_total + description: The total time the I/O thread spent doing I/O + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.metadata_age + description: The age in seconds of the current producer metadata being used. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.network_io_rate + description: The number of network operations (reads or writes) on all connections + per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.network_io_total + description: The total number of network operations (reads or writes) on all + connections + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.outgoing_byte_rate + description: The number of outgoing bytes sent to all servers per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.outgoing_byte_total + description: The total number of outgoing bytes sent to all servers + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.produce_throttle_time_avg + description: The average time in ms a request was throttled by a broker + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.produce_throttle_time_max + description: The maximum time in ms a request was throttled by a broker + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.record_error_rate + description: The average per-second number of record sends that resulted in + errors + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.record_error_total + description: The total number of record sends that resulted in errors + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.record_queue_time_avg + description: The average time in ms record batches spent in the send buffer. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.record_queue_time_max + description: The maximum time in ms record batches spent in the send buffer. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.record_retry_rate + description: The average per-second number of retried record sends + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.record_retry_total + description: The total number of retried record sends + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.record_send_rate + description: The average number of records sent per second. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.record_send_total + description: The total number of records sent. + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: topic + type: STRING + - name: kafka.producer.record_size_avg + description: The average record size + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.record_size_max + description: The maximum record size + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.records_per_request_avg + description: The average number of records per request. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.request_latency_avg + description: The average request latency in ms + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.request_latency_max + description: The maximum request latency in ms + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.request_rate + description: The number of requests sent per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.request_size_avg + description: The average size of requests sent. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.request_size_max + description: The maximum size of any request sent. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.request_total + description: The total number of requests sent + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.requests_in_flight + description: The current number of in-flight requests awaiting a response. + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.response_rate + description: The number of responses received per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.response_total + description: The total number of responses received + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: node-id + type: STRING + - name: kafka.producer.select_rate + description: The number of times the I/O layer checked for new I/O to perform + per second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.select_total + description: The total number of times the I/O layer checked for new I/O to + perform + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.successful_authentication_no_reauth_total + description: The total number of connections with successful authentication + where the client does not support re-authentication + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.successful_authentication_rate + description: The number of connections with successful authentication per + second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.successful_authentication_total + description: The total number of connections with successful authentication + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.successful_reauthentication_rate + description: The number of successful re-authentication of connections per + second + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.successful_reauthentication_total + description: The total number of successful re-authentication of connections + type: DOUBLE_SUM + unit: '' + attributes: + - name: client-id + type: STRING + - name: kafka.producer.waiting_threads + description: The number of user threads blocked waiting for buffer memory + to enqueue their records + type: DOUBLE_GAUGE + unit: '' + attributes: + - name: client-id + type: STRING + spans: + - span_kind: CONSUMER + attributes: + - name: kafka.record.queue_time_ms + type: LONG + - name: messaging.batch.message_count + type: LONG + - name: messaging.client_id + type: STRING + - name: messaging.destination.name + type: STRING + - name: messaging.destination.partition.id + type: STRING + - name: messaging.kafka.consumer.group + type: STRING + - name: messaging.kafka.message.offset + type: LONG + - name: messaging.message.body.size + type: LONG + - name: messaging.operation + type: STRING + - name: messaging.system + type: STRING + - span_kind: PRODUCER + attributes: + - name: messaging.client_id + type: STRING + - name: messaging.destination.name + type: STRING + - name: messaging.destination.partition.id + type: STRING + - name: messaging.kafka.message.offset + type: LONG + - name: messaging.operation + type: STRING + - name: messaging.system + type: STRING + - name: kafka-connect-2.6 + display_name: Apache Kafka Connect + description: This instrumentation enables messaging spans for Kafka Connect sink + tasks. + semantic_conventions: + - MESSAGING_SPANS + library_link: https://kafka.apache.org/documentation/#connect + source_path: instrumentation/kafka/kafka-connect-2.6 + scope: + name: io.opentelemetry.kafka-connect-2.6 + target_versions: + javaagent: + - org.apache.kafka:connect-api:[2.6.0,) + telemetry: + - when: default + spans: + - span_kind: CONSUMER + attributes: + - name: messaging.batch.message_count + type: LONG + - name: messaging.destination.name + type: STRING + - name: messaging.operation + type: STRING + - name: messaging.system + type: STRING + - name: thread.id + type: LONG + - name: thread.name + type: STRING + - name: kafka-streams-0.11 + display_name: Apache Kafka Streams + description: This instrumentation enables messaging spans for Kafka Streams processing. + semantic_conventions: + - MESSAGING_SPANS + library_link: https://kafka.apache.org/documentation/streams/ + source_path: instrumentation/kafka/kafka-streams-0.11 + scope: + name: io.opentelemetry.kafka-streams-0.11 target_versions: javaagent: - org.apache.kafka:kafka-streams:[0.11.0.0,) @@ -8311,8 +10883,6 @@ libraries: spans: - span_kind: CONSUMER attributes: - - name: asdf - type: STRING - name: messaging.client_id type: STRING - name: messaging.destination.name @@ -8335,8 +10905,6 @@ libraries: spans: - span_kind: CONSUMER attributes: - - name: asdf - type: STRING - name: kafka.record.queue_time_ms type: LONG - name: messaging.client_id