You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by lu...@apache.org on 2025/12/15 10:29:40 UTC
(kafka) branch 4.2 updated (4bacbce15a2 -> 6351bb433cb)
This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a change to branch 4.2
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 4bacbce15a2 KAFKA-19959: Update session and window store with new default when no open iterators (#21120)
new 35330313ef4 KAFKA-19985: Document streams groups metrics changes in ops.html (#21129)
new 6351bb433cb KAFKA-19987: Add metrics from KIP-1216 to ops.html (#21130)
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/ops.html | 49 +++++++++++++++++++++++++++++++++++++++++++++++--
1 file changed, 47 insertions(+), 2 deletions(-)
(kafka) 02/02: KAFKA-19987: Add metrics from KIP-1216 to ops.html (#21130)
Posted by lu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a commit to branch 4.2
in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 6351bb433cb5901ddb042e788abfc20e3e7a0bc4
Author: Lucas Brutschy <lb...@confluent.io>
AuthorDate: Mon Dec 15 09:44:54 2025 +0100
KAFKA-19987: Add metrics from KIP-1216 to ops.html (#21130)
This commit adds the new thread-level rebalance listener callback
metrics from KIP-1216 to the Streams Monitoring section in ops.html:
- tasks-revoked-latency-avg and tasks-revoked-latency-max
- tasks-assigned-latency-avg and tasks-assigned-latency-max
- tasks-lost-latency-avg and tasks-lost-latency-max
All metrics are at the INFO recording level and measure time in
milliseconds.
Reviewers: Matthias J. Sax <ma...@confluent.io>
---
docs/ops.html | 30 ++++++++++++++++++++++++++++++
1 file changed, 30 insertions(+)
diff --git a/docs/ops.html b/docs/ops.html
index 2319ebe9631..31d75a5d074 100644
--- a/docs/ops.html
+++ b/docs/ops.html
@@ -3246,6 +3246,36 @@ All the following metrics have a recording level of <code>info</code>:
<td>The system timestamp in ms that the thread was started.</td>
<td>kafka.streams:type=stream-thread-metrics,thread-id=([-.\w]+)</td>
</tr>
+ <tr>
+ <td>tasks-revoked-latency-avg</td>
+ <td>The average time in ms taken for tasks-revoked rebalance listener callback.</td>
+ <td>kafka.streams:type=stream-thread-metrics,thread-id=([-.\w]+)</td>
+ </tr>
+ <tr>
+ <td>tasks-revoked-latency-max</td>
+ <td>The maximum time in ms taken for tasks-revoked rebalance listener callback.</td>
+ <td>kafka.streams:type=stream-thread-metrics,thread-id=([-.\w]+)</td>
+ </tr>
+ <tr>
+ <td>tasks-assigned-latency-avg</td>
+ <td>The average time in ms taken for tasks-assigned rebalance listener callback.</td>
+ <td>kafka.streams:type=stream-thread-metrics,thread-id=([-.\w]+)</td>
+ </tr>
+ <tr>
+ <td>tasks-assigned-latency-max</td>
+ <td>The maximum time in ms taken for tasks-assigned rebalance listener callback.</td>
+ <td>kafka.streams:type=stream-thread-metrics,thread-id=([-.\w]+)</td>
+ </tr>
+ <tr>
+ <td>tasks-lost-latency-avg</td>
+ <td>The average time in ms taken for tasks-lost rebalance listener callback.</td>
+ <td>kafka.streams:type=stream-thread-metrics,thread-id=([-.\w]+)</td>
+ </tr>
+ <tr>
+ <td>tasks-lost-latency-max</td>
+ <td>The maximum time in ms taken for tasks-lost rebalance listener callback.</td>
+ <td>kafka.streams:type=stream-thread-metrics,thread-id=([-.\w]+)</td>
+ </tr>
</tbody>
</table>
(kafka) 01/02: KAFKA-19985: Document streams groups metrics changes in ops.html (#21129)
Posted by lu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a commit to branch 4.2
in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 35330313ef402d4eac973569bcc2b62576eaa992
Author: Lucas Brutschy <lb...@confluent.io>
AuthorDate: Mon Dec 15 09:44:37 2025 +0100
KAFKA-19985: Document streams groups metrics changes in ops.html (#21129)
Added documentation for KIP-1071 broker metrics:
- Extended group-count metric to include protocol=streams
- Added streams-group-count metric with states: empty, not_ready,
assigning, reconciling, stable, dead
- Added streams-group-rebalance-rate and streams-group-rebalance-count
metrics
Reviewers: Matthias J. Sax <ma...@confluent.io>
---
docs/ops.html | 19 +++++++++++++++++--
1 file changed, 17 insertions(+), 2 deletions(-)
diff --git a/docs/ops.html b/docs/ops.html
index 10eba0aca9f..2319ebe9631 100644
--- a/docs/ops.html
+++ b/docs/ops.html
@@ -1939,8 +1939,8 @@ The following set of metrics are available for monitoring the group coordinator:
</tr>
<tr>
<td>Group Count, per group type</td>
- <td>kafka.server:type=group-coordinator-metrics,name=group-count,protocol={consumer|classic}</td>
- <td>Total number of group per group type: Classic or Consumer</td>
+ <td>kafka.server:type=group-coordinator-metrics,name=group-count,protocol={consumer|classic|streams}</td>
+ <td>Total number of group per group type: Classic, Consumer or Streams</td>
</tr>
<tr>
<td>Consumer Group Count, per state</td>
@@ -1957,6 +1957,21 @@ The following set of metrics are available for monitoring the group coordinator:
<td>kafka.server:type=group-coordinator-metrics,name=consumer-group-rebalance-count</td>
<td>Total number of Consumer Group Rebalances</td>
</tr>
+ <tr>
+ <td>Streams Group Count, per state</td>
+ <td>kafka.server:type=group-coordinator-metrics,name=streams-group-count,state=[empty|not_ready|assigning|reconciling|stable|dead]</td>
+ <td>Total number of Streams Groups in each state: Empty, Not Ready, Assigning, Reconciling, Stable, Dead</td>
+ </tr>
+ <tr>
+ <td>Streams Group Rebalance Rate</td>
+ <td>kafka.server:type=group-coordinator-metrics,name=streams-group-rebalance-rate</td>
+ <td>The rebalance rate of streams groups</td>
+ </tr>
+ <tr>
+ <td>Streams Group Rebalance Count</td>
+ <td>kafka.server:type=group-coordinator-metrics,name=streams-group-rebalance-count</td>
+ <td>Total number of Streams Group Rebalances</td>
+ </tr>
<tr>
<td>Classic Group Count</td>
<td>kafka.server:type=GroupMetadataManager,name=NumGroups</td>