Skip to content

Conversation

@lucasbru
Copy link
Member

@lucasbru lucasbru commented Dec 11, 2025

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 [email protected]

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.
Copy link
Contributor

Copilot AI left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Pull request overview

This PR adds six new thread-level rebalance listener callback metrics from KIP-1216 to the Kafka Streams monitoring documentation in ops.html.

Key Changes:

  • Added documentation for tasks-revoked-latency-avg and tasks-revoked-latency-max metrics
  • Added documentation for tasks-assigned-latency-avg and tasks-assigned-latency-max metrics
  • Added documentation for tasks-lost-latency-avg and tasks-lost-latency-max metrics

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

</tr>
<tr>
<td>tasks-lost-latency-max</td>
<td>The maximum time in ms taken for tasks-lost rebalance listener callback.</td>
Copy link

Copilot AI Dec 11, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The description should use "execution time" instead of "time" to be consistent with other thread-level latency metrics in this section (e.g., commit-latency-max, poll-latency-max, process-latency-max). Additionally, add a comma after "ms" to match the formatting pattern used by other thread metrics.

Suggested change
<td>The maximum time in ms taken for tasks-lost rebalance listener callback.</td>
<td>The maximum execution time in ms, taken for tasks-lost rebalance listener callback.</td>

Copilot uses AI. Check for mistakes.
</tr>
<tr>
<td>tasks-revoked-latency-avg</td>
<td>The average time in ms taken for tasks-revoked rebalance listener callback.</td>
Copy link

Copilot AI Dec 11, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The description should use "execution time" instead of "time" to be consistent with other thread-level latency metrics in this section (e.g., commit-latency-avg, poll-latency-avg, process-latency-avg). Additionally, add a comma after "ms" to match the formatting pattern used by other thread metrics.

Suggested change
<td>The average time in ms taken for tasks-revoked rebalance listener callback.</td>
<td>The average execution time in ms, taken for tasks-revoked rebalance listener callback.</td>

Copilot uses AI. Check for mistakes.
</tr>
<tr>
<td>tasks-revoked-latency-max</td>
<td>The maximum time in ms taken for tasks-revoked rebalance listener callback.</td>
Copy link

Copilot AI Dec 11, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The description should use "execution time" instead of "time" to be consistent with other thread-level latency metrics in this section (e.g., commit-latency-max, poll-latency-max, process-latency-max). Additionally, add a comma after "ms" to match the formatting pattern used by other thread metrics.

Suggested change
<td>The maximum time in ms taken for tasks-revoked rebalance listener callback.</td>
<td>The maximum execution time in ms, taken for tasks-revoked rebalance listener callback.</td>

Copilot uses AI. Check for mistakes.
</tr>
<tr>
<td>tasks-assigned-latency-avg</td>
<td>The average time in ms taken for tasks-assigned rebalance listener callback.</td>
Copy link

Copilot AI Dec 11, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The description should use "execution time" instead of "time" to be consistent with other thread-level latency metrics in this section (e.g., commit-latency-avg, poll-latency-avg, process-latency-avg). Additionally, add a comma after "ms" to match the formatting pattern used by other thread metrics.

Suggested change
<td>The average time in ms taken for tasks-assigned rebalance listener callback.</td>
<td>The average execution time in ms, taken for tasks-assigned rebalance listener callback.</td>

Copilot uses AI. Check for mistakes.
</tr>
<tr>
<td>tasks-assigned-latency-max</td>
<td>The maximum time in ms taken for tasks-assigned rebalance listener callback.</td>
Copy link

Copilot AI Dec 11, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The description should use "execution time" instead of "time" to be consistent with other thread-level latency metrics in this section (e.g., commit-latency-max, poll-latency-max, process-latency-max). Additionally, add a comma after "ms" to match the formatting pattern used by other thread metrics.

Suggested change
<td>The maximum time in ms taken for tasks-assigned rebalance listener callback.</td>
<td>The maximum execution time in ms, taken for tasks-assigned rebalance listener callback.</td>

Copilot uses AI. Check for mistakes.
</tr>
<tr>
<td>tasks-lost-latency-avg</td>
<td>The average time in ms taken for tasks-lost rebalance listener callback.</td>
Copy link

Copilot AI Dec 11, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The description should use "execution time" instead of "time" to be consistent with other thread-level latency metrics in this section (e.g., commit-latency-avg, poll-latency-avg, process-latency-avg). Additionally, add a comma after "ms" to match the formatting pattern used by other thread metrics.

Suggested change
<td>The average time in ms taken for tasks-lost rebalance listener callback.</td>
<td>The average execution time in ms, taken for tasks-lost rebalance listener callback.</td>

Copilot uses AI. Check for mistakes.
@lucasbru lucasbru added the KIP-1071 PRs related to KIP-1071 label Dec 15, 2025
@lucasbru lucasbru merged commit 08aadb7 into apache:trunk Dec 15, 2025
33 checks passed
@lucasbru
Copy link
Member Author

picked to 4.2

lucasbru added a commit that referenced this pull request Dec 15, 2025
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 <[email protected]>
shashankhs11 pushed a commit to shashankhs11/kafka that referenced this pull request Dec 15, 2025
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 <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

docs KIP-1071 PRs related to KIP-1071 small Small PRs

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants