Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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-

age

time-avg

org.apache.kafka.consumer.application.event.queue.

age

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-

age

time-max

org.apache.kafka.consumer.unsent.requests.queue.

age

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-

age

queue-time-avg

org.apache.kafka.consumer.unsent.requests.

age

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.

...