You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "John Roesler (Jira)" <ji...@apache.org> on 2022/09/21 22:37:00 UTC

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

John Roesler created KAFKA-14253:
------------------------------------

             Summary: 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


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)