KIP-1350 — Expose Streams Group Heartbeat Statuses as Kafka Streams Metrics

Discussion StreamsMetrics

Exposes the statuses carried in StreamsGroupHeartbeatResponse (MISSING_SOURCE_TOPICS, ASSIGNMENT_DELAYED, SHUTDOWN_APPLICATION, etc.) as a thread-level heartbeat-status gauge tagged by thread-id and status, valued 1 when the latest successful heartbeat response carries that status. Under the Streams rebalance protocol these coordinator-reported conditions are only visible in client logs, so operators must locate the specific client and thread by hand to explain why a thread is idle or an assignment is delayed.

Protocol Impact

Heartbeat · StreamsGroupHeartbeat

Details