[ https://issues.apache.org/jira/browse/KAFKA-14253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Guozhang Wang resolved KAFKA-14253. ----------------------------------- Fix Version/s: 3.5.0 Resolution: Fixed > 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++ > Fix For: 3.5.0 > > > 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)