...
Public Interfaces
New Metrics
Metric Name | Telemetry Metric Name | Data Type | Description | MBean |
---|---|---|---|---|
time-between-network-thread-poll-max | org.apache.kafka.consumer.time.between.network.thread.poll.max | long | The maximum time taken, in milliseconds, between each poll in the network thread each time the thread is run | kafka.consumer:type=consumer-metrics,client-id={clientId} |
time-between-network-thread-poll-avg | org.apache.kafka.consumer.time.between.network.thread.poll.avg | long | The average time taken, in milliseconds, between each poll in the network thread each time the thread is run | kafka.consumer:type=consumer-metrics,client-id={clientId} |
application-event-queue-size | org.apache.kafka.consumer.application.event.queue.size | int | The current number of events in the consumer network application event queue | kafka.consumer:type=consumer-metrics,client-id={clientId} |
application-event-queue- |
time-avg | org.apache.kafka.consumer.application.event.queue. |
time.avg | long | The average time, in milliseconds, that application events are taking to be dequeued | kafka.consumer:type=consumer-metrics,client-id={clientId} | |
application-event-queue-time-max | org.apache.kafka.consumer.application.event.queue.time.max | long | The maximum time, in milliseconds, that an application event took to be dequeued | kafka.consumer:type=consumer-metrics,client-id={clientId} |
application-event-queue-processing-time-avg | org.apache.kafka.consumer.application.event.queue.processing.time.avg | long | The average time, in milliseconds, that the consumer network takes to process all available events | kafka.consumer:type=consumer-metrics,client-id={clientId} |
application-event-queue-processing-time-max | org.apache.kafka.consumer.application.event.queue.processing.time.max | long | The maximum time, in milliseconds, that the consumer network took to process all available events | kafka.consumer:type=consumer-metrics,client-id={clientId} |
unsent-requests-queue-size | org.apache.kafka.consumer.unsent.requests.queue.size | int | The current number of unsent requests in the consumer network | kafka.consumer:type=consumer-metrics,client-id={clientId} |
unsent-requests-queue- |
time-max | org.apache.kafka.consumer.unsent.requests.queue. |
time.max | long | The maximum time, in milliseconds, that a request remained unsent in the consumer network | kafka.consumer:type=consumer-metrics,client-id={clientId} |
unsent-requests- |
queue-time-avg | org.apache.kafka.consumer.unsent.requests. |
queue.time.avg | long | The average time, in milliseconds, that requests are taking to be sent in the consumer network | kafka.consumer:type=consumer-metrics,client-id={clientId} | |
background-event-queue-size | org.apache.kafka.consumer.background.event.queue.size | int | The current number of events in the consumer background event queue | kafka.consumer:type=consumer-metrics,client-id={clientId} |
Compatibility, Deprecation, and Migration Plan
Since only new metrics are being proposed, there should be no compatibility issues.
...