Versions Compared

Key

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

...

Values for client-state metrics

The client-state  metric values will reflect the current state of the Kafka Streams client instance, represented by the value returned by KafkaStreams.State.ordinal() of the current state enum.

Client StateMetric Value
CREATED0
REBALANCING1
RUNNING2
PENDING_SHUTDOWN3
NOT_RUNNING4
PENDING_ERROR5
ERROR6

Values for thread-state metrics (KIP-1076 extension)

The thread-state  metric values will reflect the current state of a StreamThread  instance, represented by the value returned by StreamThread.State  enum.ordinal()  of the current state enum.

Thread StateMetric Value
CREATED0
STARTING1
PARTITIONS_REVOKED2
PARTITIONS_ASSIGNED3
RUNNING4
PENDING_SHUTDOWN5
DEAD6

Values for thread-state metrics (JMX)

The thread-state  metric for JMX reporters will also reflect the current state represented by the current StreamThread.State, but the metric will be the string value of enum name.

Thread StateMetric Value
CREATED"created"
STARTING"starting"
PARTITIONS_REVOKED"partitions_revoked"
PARTITIONS_ASSIGNED"partitions_assigned"
RUNNING"running"
PENDING_SHUTDOWN"pending_shutdown"
DEAD"dead"

Values for recording-level metrics

...