From 4a26acc7a2be3ceb8d7aecc4d9c6b4aaa0586e33 Mon Sep 17 00:00:00 2001 From: jcountsNR <94138069+jcountsNR@users.noreply.github.com> Date: Fri, 14 Jul 2023 13:58:44 -0700 Subject: [PATCH 1/8] chore: update kafka.md --- docs/messaging/kafka.md | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/docs/messaging/kafka.md b/docs/messaging/kafka.md index 47d36bb22f..d0dfc6e493 100644 --- a/docs/messaging/kafka.md +++ b/docs/messaging/kafka.md @@ -112,8 +112,17 @@ This section defines how to apply semantic conventions when collecting Kafka met | messaging.kafka.leader.elections | Counter | Int64 | elections | `{election}` | Leader election rate (increasing values indicates broker failures). | | | | messaging.kafka.leader.unclean-elections | Counter | Int64 | elections | `{election}` | Unclean leader election rate (increasing values indicates broker failures). | | | | messaging.kafka.brokers | UpDownCounter | Int64 | brokers | `{broker}` | Number of brokers in the cluster. | | | +| messaging.kafka.brokers.count | UpDownCounter | Int64 | brokers | `{broker}` | sum of brokers in the cluster | | | +| messaging.kafka.brokers.consumer.fetch.rate | Gauge | Double | fetches per second | `{fetch}/s` | Average consumer fetch Rate. | `state` | `in`, `out` | +| messaging.kafka.brokers.network.io | Gauge | Double | bytes per second | `{By/s}` | Average tncoming Byte Rate in bytes/second. | | | +| messaging.kafka.brokers.requests.latency | Gauge | Double | ms | `{ms}` | Average Request latency in ms. | | | +| messaging.kafka.brokers.requests.rate | Gauge | Double | requests per second | `{request}/s`| Average request rate per second. | | | +| messaging.kafka.brokers.requsts.size | Gauge | Double | bytes | `By` | Average request size in bytes. | | | +| messaging.kafka.brokers.responses.rate | Gauge | Double | responses per second| `{response}/s`| Average response rate per second. | | | +| messaging.kafka.brokers.response_size | Gauge | Double | bytes | `By` | Average response size in bytes. | | | +| messaging.kafka.brokers.requests.in.flight | Gauge | Int64 | requests | `{request}` | Requests in flight. | | | | messaging.kafka.topic.partitions | UpDownCounter | Int64 | partitions | `{partition}` | Number of partitions in topic. | `topic` | The ID (integer) of a topic | -| messaging.kafka.partition.current_offset | Gauge | Int64 | partition offset | `{partition offset}` | Current offset of partition of topic. | `topic` | The ID (integer) of a topic | +| messaging.kafka.partition.current.offset | Gauge | Int64 | partition offset | `{partition offset}` | Current offset of partition of topic. | `topic` | The ID (integer) of a topic | | | | | | | | `partition` | The number (integer) of the partition | | messaging.kafka.partition.oldest_offset | Gauge | Int64 | partition offset | `{partition offset}` | Oldest offset of partition of topic | `topic` | The ID (integer) of a topic | | | | | | | | `partition` | The number (integer) of the partition | From fbe1e33127f534182f93b6a44a0ef3e8f64b50e3 Mon Sep 17 00:00:00 2001 From: jcountsNR <94138069+jcountsNR@users.noreply.github.com> Date: Fri, 14 Jul 2023 14:01:13 -0700 Subject: [PATCH 2/8] chore: fix --- docs/messaging/kafka.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/messaging/kafka.md b/docs/messaging/kafka.md index d0dfc6e493..c271c0d8d6 100644 --- a/docs/messaging/kafka.md +++ b/docs/messaging/kafka.md @@ -122,7 +122,7 @@ This section defines how to apply semantic conventions when collecting Kafka met | messaging.kafka.brokers.response_size | Gauge | Double | bytes | `By` | Average response size in bytes. | | | | messaging.kafka.brokers.requests.in.flight | Gauge | Int64 | requests | `{request}` | Requests in flight. | | | | messaging.kafka.topic.partitions | UpDownCounter | Int64 | partitions | `{partition}` | Number of partitions in topic. | `topic` | The ID (integer) of a topic | -| messaging.kafka.partition.current.offset | Gauge | Int64 | partition offset | `{partition offset}` | Current offset of partition of topic. | `topic` | The ID (integer) of a topic | +| messaging.kafka.partition.current_offset | Gauge | Int64 | partition offset | `{partition offset}` | Current offset of partition of topic. | `topic` | The ID (integer) of a topic | | | | | | | | `partition` | The number (integer) of the partition | | messaging.kafka.partition.oldest_offset | Gauge | Int64 | partition offset | `{partition offset}` | Oldest offset of partition of topic | `topic` | The ID (integer) of a topic | | | | | | | | `partition` | The number (integer) of the partition | From 1fb25d14221b7e5fd8eb5a8f8795974140b1af61 Mon Sep 17 00:00:00 2001 From: Joseph Counts <94138069+jcountsNR@users.noreply.github.com> Date: Tue, 18 Jul 2023 08:53:29 -0700 Subject: [PATCH 3/8] Update docs/messaging/kafka.md Co-authored-by: Dmitrii Anoshin --- docs/messaging/kafka.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/messaging/kafka.md b/docs/messaging/kafka.md index c271c0d8d6..43c3a05600 100644 --- a/docs/messaging/kafka.md +++ b/docs/messaging/kafka.md @@ -114,7 +114,7 @@ This section defines how to apply semantic conventions when collecting Kafka met | messaging.kafka.brokers | UpDownCounter | Int64 | brokers | `{broker}` | Number of brokers in the cluster. | | | | messaging.kafka.brokers.count | UpDownCounter | Int64 | brokers | `{broker}` | sum of brokers in the cluster | | | | messaging.kafka.brokers.consumer.fetch.rate | Gauge | Double | fetches per second | `{fetch}/s` | Average consumer fetch Rate. | `state` | `in`, `out` | -| messaging.kafka.brokers.network.io | Gauge | Double | bytes per second | `{By/s}` | Average tncoming Byte Rate in bytes/second. | | | +| messaging.kafka.brokers.network.io | Counter | Int64 | bytes | `By` | The bytes received or sent by the broker. | | | | messaging.kafka.brokers.requests.latency | Gauge | Double | ms | `{ms}` | Average Request latency in ms. | | | | messaging.kafka.brokers.requests.rate | Gauge | Double | requests per second | `{request}/s`| Average request rate per second. | | | | messaging.kafka.brokers.requsts.size | Gauge | Double | bytes | `By` | Average request size in bytes. | | | From 25f4535cf6ea437fd87e28cfedb40a9315e80b5d Mon Sep 17 00:00:00 2001 From: jcountsNR <94138069+jcountsNR@users.noreply.github.com> Date: Tue, 18 Jul 2023 10:21:32 -0700 Subject: [PATCH 4/8] chore: move broker metrics --- docs/messaging/kafka.md | 26 ++++++++++++++++---------- 1 file changed, 16 insertions(+), 10 deletions(-) diff --git a/docs/messaging/kafka.md b/docs/messaging/kafka.md index 43c3a05600..51af0e848f 100644 --- a/docs/messaging/kafka.md +++ b/docs/messaging/kafka.md @@ -111,16 +111,6 @@ This section defines how to apply semantic conventions when collecting Kafka met | messaging.kafka.controllers.active | UpDownCounter | Int64 | controllers | `{controller}` | The number of active controllers in the broker. | | | | messaging.kafka.leader.elections | Counter | Int64 | elections | `{election}` | Leader election rate (increasing values indicates broker failures). | | | | messaging.kafka.leader.unclean-elections | Counter | Int64 | elections | `{election}` | Unclean leader election rate (increasing values indicates broker failures). | | | -| messaging.kafka.brokers | UpDownCounter | Int64 | brokers | `{broker}` | Number of brokers in the cluster. | | | -| messaging.kafka.brokers.count | UpDownCounter | Int64 | brokers | `{broker}` | sum of brokers in the cluster | | | -| messaging.kafka.brokers.consumer.fetch.rate | Gauge | Double | fetches per second | `{fetch}/s` | Average consumer fetch Rate. | `state` | `in`, `out` | -| messaging.kafka.brokers.network.io | Counter | Int64 | bytes | `By` | The bytes received or sent by the broker. | | | -| messaging.kafka.brokers.requests.latency | Gauge | Double | ms | `{ms}` | Average Request latency in ms. | | | -| messaging.kafka.brokers.requests.rate | Gauge | Double | requests per second | `{request}/s`| Average request rate per second. | | | -| messaging.kafka.brokers.requsts.size | Gauge | Double | bytes | `By` | Average request size in bytes. | | | -| messaging.kafka.brokers.responses.rate | Gauge | Double | responses per second| `{response}/s`| Average response rate per second. | | | -| messaging.kafka.brokers.response_size | Gauge | Double | bytes | `By` | Average response size in bytes. | | | -| messaging.kafka.brokers.requests.in.flight | Gauge | Int64 | requests | `{request}` | Requests in flight. | | | | messaging.kafka.topic.partitions | UpDownCounter | Int64 | partitions | `{partition}` | Number of partitions in topic. | `topic` | The ID (integer) of a topic | | messaging.kafka.partition.current_offset | Gauge | Int64 | partition offset | `{partition offset}` | Current offset of partition of topic. | `topic` | The ID (integer) of a topic | | | | | | | | `partition` | The number (integer) of the partition | @@ -168,4 +158,20 @@ This section defines how to apply semantic conventions when collecting Kafka met | messaging.kafka.consumer.lag_sum | Gauge | Int64 | lag sum | `{lag sum}` | Current approximate sum of consumer group lag across all partitions of topic | `group` | The ID (string) of a consumer group | | | | | | | | `topic` | The ID (integer) of a topic | +### Broker Metrics + +**Description:** Kafka Broker level metrics. + +| Name | Instrument | Value type | Unit | Unit ([UCUM](/docs/general/metrics.md#instrument-units)) | Description | Attribute Key | Attribute Values | +| ---------------------------------------------| ------------- | ---------- | ------ | -------------------------------------------- | -------------- | ------------- | ---------------- | +| messaging.kafka.brokers.count | UpDownCounter | Int64 | brokers | `{broker}` | sum of brokers in the cluster | | | +| messaging.kafka.brokers.consumer.fetch.rate | Gauge | Double | fetches per second | `{fetch}/s` | Average consumer fetch Rate. | `state` | `in`, `out` | +| messaging.kafka.brokers.network.io | Counter | Int64 | bytes | `By` | The bytes received or sent by the broker. | | | +| messaging.kafka.brokers.requests.latency | Gauge | Double | ms | `{ms}` | Average Request latency in ms. | | | +| messaging.kafka.brokers.requests.rate | Gauge | Double | requests per second | `{request}/s`| Average request rate per second. | | | +| messaging.kafka.brokers.requsts.size | Gauge | Double | bytes | `By` | Average request size in bytes. | | | +| messaging.kafka.brokers.responses.rate | Gauge | Double | responses per second| `{response}/s`| Average response rate per second. | | | +| messaging.kafka.brokers.response_size | Gauge | Double | bytes | `By` | Average response size in bytes. | | | +| messaging.kafka.brokers.requests.in.flight | Gauge | Int64 | requests | `{request}` | Requests in flight. | | | + [DocumentStatus]: https://github.com/open-telemetry/opentelemetry-specification/tree/v1.22.0/specification/document-status.md From fbcd579e81c7577534726063d1821d88b0e00758 Mon Sep 17 00:00:00 2001 From: jcountsNR <94138069+jcountsNR@users.noreply.github.com> Date: Thu, 3 Aug 2023 19:42:58 -0700 Subject: [PATCH 5/8] chore: updates --- docs/messaging/kafka.md | 27 ++++++++++++++------------- 1 file changed, 14 insertions(+), 13 deletions(-) diff --git a/docs/messaging/kafka.md b/docs/messaging/kafka.md index 51af0e848f..7c5803b9fd 100644 --- a/docs/messaging/kafka.md +++ b/docs/messaging/kafka.md @@ -162,16 +162,17 @@ This section defines how to apply semantic conventions when collecting Kafka met **Description:** Kafka Broker level metrics. -| Name | Instrument | Value type | Unit | Unit ([UCUM](/docs/general/metrics.md#instrument-units)) | Description | Attribute Key | Attribute Values | -| ---------------------------------------------| ------------- | ---------- | ------ | -------------------------------------------- | -------------- | ------------- | ---------------- | -| messaging.kafka.brokers.count | UpDownCounter | Int64 | brokers | `{broker}` | sum of brokers in the cluster | | | -| messaging.kafka.brokers.consumer.fetch.rate | Gauge | Double | fetches per second | `{fetch}/s` | Average consumer fetch Rate. | `state` | `in`, `out` | -| messaging.kafka.brokers.network.io | Counter | Int64 | bytes | `By` | The bytes received or sent by the broker. | | | -| messaging.kafka.brokers.requests.latency | Gauge | Double | ms | `{ms}` | Average Request latency in ms. | | | -| messaging.kafka.brokers.requests.rate | Gauge | Double | requests per second | `{request}/s`| Average request rate per second. | | | -| messaging.kafka.brokers.requsts.size | Gauge | Double | bytes | `By` | Average request size in bytes. | | | -| messaging.kafka.brokers.responses.rate | Gauge | Double | responses per second| `{response}/s`| Average response rate per second. | | | -| messaging.kafka.brokers.response_size | Gauge | Double | bytes | `By` | Average response size in bytes. | | | -| messaging.kafka.brokers.requests.in.flight | Gauge | Int64 | requests | `{request}` | Requests in flight. | | | - -[DocumentStatus]: https://github.com/open-telemetry/opentelemetry-specification/tree/v1.22.0/specification/document-status.md +| Name | Instrument | Value type | Unit | Unit ([UCUM](/docs/general/metrics.md#instrument-units)) | Description | Attribute Key | Attribute Values | +| -------------------------------------------- | ------------- | ---------- | -------------------- | -------------- | ----------------------------------- | ------------- | ---------------- | +| messaging.kafka.broker.count | Counter | Int64 | brokers | `{broker}` | Number of brokers | | | +| messaging.kafka.broker.consumer_fetch_count | Gauge | Double | fetches per second | `{fetch}/s` | Average consumer fetch Rate. | `node` | The ID (integer) of the broker | +| messaging.kafka.broker.incoming_byte_rate | Gauge | Double | bytes | `By` | Bytes received by the broker. | `node` | The ID (integer) of the broker | +| messaging.kafka.broker.outgoing_byte_rate | Gauge | Double | bytes | `By` | Bytes sent by the broker. | `node` | The ID (integer) of the broker | +| messaging.kafka.broker.requests_latency | Gauge | Double | ms | `{ms}` | Average Request latency in ms. | `node` | The ID (integer) of the broker | +| messaging.kafka.broker.requests_count | Counter | Double | requests | `{request}/s` | Number of requests in the broker | `node` | The ID (integer) of the broker | +| messaging.kafka.broker.requsts_size | Gauge | Double | bytes | `By` | Average request size in bytes. | `node` | The ID (integer) of the broker | +| messaging.kafka.broker.responses_count | Counter | Double | responses | `{response}/s` | Number of responses from the broker | `node` | The ID (integer) of the broker | +| messaging.kafka.broker.response_size | Gauge | Double | bytes | `By` | Average response size in bytes. | `node` | The ID (integer) of the broker | +| messaging.kafka.broker.requests_in_flight | Gauge | Int64 | requests | `{request}` | Requests in flight. | `node` | The ID (integer) of the broker | + +[DocumentStatus]: https://github.com/open-telemetry/opentelemetry-specification/tree/v1.22.0/specification/document-status.md \ No newline at end of file From f88093be6168121a862929a99c8c2d4feaa158d4 Mon Sep 17 00:00:00 2001 From: jcountsNR <94138069+jcountsNR@users.noreply.github.com> Date: Thu, 3 Aug 2023 19:53:54 -0700 Subject: [PATCH 6/8] chore: minor changes --- docs/messaging/kafka.md | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/docs/messaging/kafka.md b/docs/messaging/kafka.md index 7c5803b9fd..21caa05c21 100644 --- a/docs/messaging/kafka.md +++ b/docs/messaging/kafka.md @@ -163,16 +163,16 @@ This section defines how to apply semantic conventions when collecting Kafka met **Description:** Kafka Broker level metrics. | Name | Instrument | Value type | Unit | Unit ([UCUM](/docs/general/metrics.md#instrument-units)) | Description | Attribute Key | Attribute Values | -| -------------------------------------------- | ------------- | ---------- | -------------------- | -------------- | ----------------------------------- | ------------- | ---------------- | +| -------------------------------------------- | ------------- | ---------- | -------------------- | ----------------------------------------- | ----------------------------------- | ------------- | ---------------- | | messaging.kafka.broker.count | Counter | Int64 | brokers | `{broker}` | Number of brokers | | | -| messaging.kafka.broker.consumer_fetch_count | Gauge | Double | fetches per second | `{fetch}/s` | Average consumer fetch Rate. | `node` | The ID (integer) of the broker | +| messaging.kafka.broker.consumer_fetch_count | Counter | Double | fetches | `{fetch}/s` | Count of consumer fetches | `node` | The ID (integer) of the broker | | messaging.kafka.broker.incoming_byte_rate | Gauge | Double | bytes | `By` | Bytes received by the broker. | `node` | The ID (integer) of the broker | | messaging.kafka.broker.outgoing_byte_rate | Gauge | Double | bytes | `By` | Bytes sent by the broker. | `node` | The ID (integer) of the broker | | messaging.kafka.broker.requests_latency | Gauge | Double | ms | `{ms}` | Average Request latency in ms. | `node` | The ID (integer) of the broker | | messaging.kafka.broker.requests_count | Counter | Double | requests | `{request}/s` | Number of requests in the broker | `node` | The ID (integer) of the broker | -| messaging.kafka.broker.requsts_size | Gauge | Double | bytes | `By` | Average request size in bytes. | `node` | The ID (integer) of the broker | +| messaging.kafka.broker.requsts_size | Histogram | Double | bytes | `By` | Measures the size of the request | `node` | The ID (integer) of the broker | | messaging.kafka.broker.responses_count | Counter | Double | responses | `{response}/s` | Number of responses from the broker | `node` | The ID (integer) of the broker | -| messaging.kafka.broker.response_size | Gauge | Double | bytes | `By` | Average response size in bytes. | `node` | The ID (integer) of the broker | +| messaging.kafka.broker.response_size | Histogram | Double | bytes | `By` | Measures the size of the response | `node` | The ID (integer) of the broker | | messaging.kafka.broker.requests_in_flight | Gauge | Int64 | requests | `{request}` | Requests in flight. | `node` | The ID (integer) of the broker | [DocumentStatus]: https://github.com/open-telemetry/opentelemetry-specification/tree/v1.22.0/specification/document-status.md \ No newline at end of file From 6f17ce9cd6dc5292bbc4ec5b0d4338d7a48a4d60 Mon Sep 17 00:00:00 2001 From: jcountsNR <94138069+jcountsNR@users.noreply.github.com> Date: Thu, 3 Aug 2023 20:02:10 -0700 Subject: [PATCH 7/8] chore: update node back to broker --- docs/messaging/kafka.md | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/docs/messaging/kafka.md b/docs/messaging/kafka.md index 21caa05c21..0b3e757327 100644 --- a/docs/messaging/kafka.md +++ b/docs/messaging/kafka.md @@ -164,15 +164,15 @@ This section defines how to apply semantic conventions when collecting Kafka met | Name | Instrument | Value type | Unit | Unit ([UCUM](/docs/general/metrics.md#instrument-units)) | Description | Attribute Key | Attribute Values | | -------------------------------------------- | ------------- | ---------- | -------------------- | ----------------------------------------- | ----------------------------------- | ------------- | ---------------- | -| messaging.kafka.broker.count | Counter | Int64 | brokers | `{broker}` | Number of brokers | | | -| messaging.kafka.broker.consumer_fetch_count | Counter | Double | fetches | `{fetch}/s` | Count of consumer fetches | `node` | The ID (integer) of the broker | -| messaging.kafka.broker.incoming_byte_rate | Gauge | Double | bytes | `By` | Bytes received by the broker. | `node` | The ID (integer) of the broker | -| messaging.kafka.broker.outgoing_byte_rate | Gauge | Double | bytes | `By` | Bytes sent by the broker. | `node` | The ID (integer) of the broker | -| messaging.kafka.broker.requests_latency | Gauge | Double | ms | `{ms}` | Average Request latency in ms. | `node` | The ID (integer) of the broker | -| messaging.kafka.broker.requests_count | Counter | Double | requests | `{request}/s` | Number of requests in the broker | `node` | The ID (integer) of the broker | -| messaging.kafka.broker.requsts_size | Histogram | Double | bytes | `By` | Measures the size of the request | `node` | The ID (integer) of the broker | -| messaging.kafka.broker.responses_count | Counter | Double | responses | `{response}/s` | Number of responses from the broker | `node` | The ID (integer) of the broker | -| messaging.kafka.broker.response_size | Histogram | Double | bytes | `By` | Measures the size of the response | `node` | The ID (integer) of the broker | -| messaging.kafka.broker.requests_in_flight | Gauge | Int64 | requests | `{request}` | Requests in flight. | `node` | The ID (integer) of the broker | +| messaging.kafka.broker.count | Counter | Int64 | brokers | `{broker}` | Number of brokers in the cluster | | | +| messaging.kafka.broker.consumer_fetch_count | Counter | Double | fetches | `{fetch}/s` | Count of consumer fetches | `broker` | The ID (integer) of the broker | +| messaging.kafka.broker.incoming_byte_rate | Gauge | Double | bytes | `By` | Bytes received by the broker. | `broker` | The ID (integer) of the broker | +| messaging.kafka.broker.outgoing_byte_rate | Gauge | Double | bytes | `By` | Bytes sent by the broker. | `broker` | The ID (integer) of the broker | +| messaging.kafka.broker.requests_latency | Gauge | Double | ms | `{ms}` | Average Request latency in ms. | `broker` | The ID (integer) of the broker | +| messaging.kafka.broker.requests_count | Counter | Double | requests | `{request}/s` | Number of requests in the broker | `broker` | The ID (integer) of the broker | +| messaging.kafka.broker.requsts_size | Histogram | Double | bytes | `By` | Measures the size of the request | `broker` | The ID (integer) of the broker | +| messaging.kafka.broker.responses_count | Counter | Double | responses | `{response}/s` | Number of responses from the broker | `broker` | The ID (integer) of the broker | +| messaging.kafka.broker.response_size | Histogram | Double | bytes | `By` | Measures the size of the response | `broker` | The ID (integer) of the broker | +| messaging.kafka.broker.requests_in_flight | Gauge | Int64 | requests | `{request}` | Requests in flight. | `broker` | The ID (integer) of the broker | [DocumentStatus]: https://github.com/open-telemetry/opentelemetry-specification/tree/v1.22.0/specification/document-status.md \ No newline at end of file From 57a96c675831533ff3e86879d14218f8de575039 Mon Sep 17 00:00:00 2001 From: jcountsNR <94138069+jcountsNR@users.noreply.github.com> Date: Thu, 3 Aug 2023 20:30:29 -0700 Subject: [PATCH 8/8] fix --- docs/messaging/kafka.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/messaging/kafka.md b/docs/messaging/kafka.md index 0b3e757327..fd641d9ada 100644 --- a/docs/messaging/kafka.md +++ b/docs/messaging/kafka.md @@ -166,8 +166,8 @@ This section defines how to apply semantic conventions when collecting Kafka met | -------------------------------------------- | ------------- | ---------- | -------------------- | ----------------------------------------- | ----------------------------------- | ------------- | ---------------- | | messaging.kafka.broker.count | Counter | Int64 | brokers | `{broker}` | Number of brokers in the cluster | | | | messaging.kafka.broker.consumer_fetch_count | Counter | Double | fetches | `{fetch}/s` | Count of consumer fetches | `broker` | The ID (integer) of the broker | -| messaging.kafka.broker.incoming_byte_rate | Gauge | Double | bytes | `By` | Bytes received by the broker. | `broker` | The ID (integer) of the broker | -| messaging.kafka.broker.outgoing_byte_rate | Gauge | Double | bytes | `By` | Bytes sent by the broker. | `broker` | The ID (integer) of the broker | +| messaging.kafka.broker.incoming_byte_rate | Gauge | Double | bytes per second | `By/s` | Average Bytes received per second | `broker` | The ID (integer) of the broker | +| messaging.kafka.broker.outgoing_byte_rate | Gauge | Double | bytes per second | `By/s` | Average Bytes sent per second | `broker` | The ID (integer) of the broker | | messaging.kafka.broker.requests_latency | Gauge | Double | ms | `{ms}` | Average Request latency in ms. | `broker` | The ID (integer) of the broker | | messaging.kafka.broker.requests_count | Counter | Double | requests | `{request}/s` | Number of requests in the broker | `broker` | The ID (integer) of the broker | | messaging.kafka.broker.requsts_size | Histogram | Double | bytes | `By` | Measures the size of the request | `broker` | The ID (integer) of the broker |