[jira] [Resolved] (KAFKA-14253) StreamsPartitionAssignor should print the member count in assignment logs

["Guozhang Wang (Jira)" <ji...@apache.org>]

     [ 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)