[
https://issues.apache.org/jira/browse/KAFKA-14253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christopher Pooya Razavian reassigned KAFKA-14253:
--------------------------------------------------
Assignee: Christopher Pooya Razavian
> StreamsPartitionAssignor should print the member count in assignment logs
> -------------------------------------------------------------------------
>
> Key: KAFKA-14253
> URL: https://issues.apache.org/jira/browse/KAFKA-14253
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Reporter: John Roesler
> Assignee: Christopher Pooya Razavian
> Priority: Minor
> Labels: newbie, newbie++
>
> Debugging rebalance and assignment issues is harder than it needs to be. One
> simple thing that can help is to print out information in the logs that users
> have to compute today.
> For example, the StreamsPartitionAssignor prints two messages that contain
> the the newline-delimited group membership:
> {code:java}
> [StreamsPartitionAssignor] [...-StreamThread-1] stream-thread
> [...-StreamThread-1-consumer] All members participating in this rebalance:
> <member UUID>: [<consumer ID>]
> <member UUID>: [<consumer ID>]
> <member UUID>: [<consumer ID>]{code}
> and
> {code:java}
> [StreamsPartitionAssignor] [...-StreamThread-1] stream-thread
> [...-StreamThread-1-consumer] Assigned tasks [...] including stateful [...]
> to clients as:
> <member UUID>=[activeTasks: ([...]) standbyTasks: ([...])]
> <member UUID>=[activeTasks: ([...]) standbyTasks: ([...])]
> <member UUID>=[activeTasks: ([...]) standbyTasks: ([...])
> {code}
>
> In both of these cases, it would be nice to:
> # Include the number of members in the group (I.e., "15 members
> participating" and "to 15 clients as")
> # sort the member ids (to help compare the membership and assignment across
> rebalances)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
