From c2b816cb57d16b41229f7de54f569816bf92263f Mon Sep 17 00:00:00 2001
From: Jinhe Zhang Streams API
More details can be found in KIP-1195.
+ Kafka Streams now provides rebalance listener metrics to monitor the latency of rebalance callbacks.
+ The following metrics are available at the thread level: tasks-revoked-latency-avg, tasks-revoked-latency-max,
+ tasks-assigned-latency-avg, tasks-assigned-latency-max, tasks-lost-latency-avg, and tasks-lost-latency-max.
+ These metrics are particularly useful for applications using the new Streams Rebalance Protocol (KIP-1071).
+ Users migrating from the consumer rebalance listener metrics should update their monitoring dashboards and alerts to use these new streams-specific metrics.
+ More details can be found in KIP-1216.
+
Note: Kafka Streams 4.1.0 contains a critical memory leak bug (KAFKA-19748) that affects users of range scans and certain DSL operators (session windows, sliding windows, stream-stream joins, foreign-key joins). Users running Kafka Streams should consider upgrading directly to 4.1.1 when available.
From c7d419a95560a0369fe2e7d9237b10f64f6cd4be Mon Sep 17 00:00:00 2001 From: Jinhe Zhang
- Kafka Streams now provides rebalance listener metrics to monitor the latency of rebalance callbacks.
+ Kafka Streams now provides rebalance listener metrics for "streams" groups to monitor the latency of rebalance callbacks.
The following metrics are available at the thread level: tasks-revoked-latency-avg, tasks-revoked-latency-max,
tasks-assigned-latency-avg, tasks-assigned-latency-max, tasks-lost-latency-avg, and tasks-lost-latency-max.
- These metrics are particularly useful for applications using the new Streams Rebalance Protocol (KIP-1071).
+ Note that these metrics are only populated when the Streams Rebalance Protocol (KIP-1071) is enabled.
Users migrating from the consumer rebalance listener metrics should update their monitoring dashboards and alerts to use these new streams-specific metrics.
- More details can be found in KIP-1216.
+ More details can be found in KIP-1216.