[jira] [Commented] (KAFKA-16038) Periodic Logging of Current Assignment

["Lucas Brutschy (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-16038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799301#comment-17799301 ] 

Lucas Brutschy commented on KAFKA-16038:
----------------------------------------

That's a good idea

> Periodic Logging of Current Assignment
> --------------------------------------
>
>                 Key: KAFKA-16038
>                 URL: https://issues.apache.org/jira/browse/KAFKA-16038
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>            Reporter: Almog Gavra
>            Assignee: Almog Gavra
>            Priority: Major
>
> Currently, assignment is only logged when a re-balance happens:
> {code:java}
> 15:14:56.263 [metrics-backend-8-a90ee750-e4bb-46d5-bb7d-32411a75dd26-StreamThread-1] INFO  org.apache.kafka.streams.processor.internals.TaskManager {} - stream-thread [metrics-backend-8-a90ee750-e4bb-46d5-bb7d-32411a75dd26-StreamThread-1] Handle new assignment with:
>     New active tasks: [0_7, 0_6, 0_5, 0_4, 0_3, 0_2, 0_1, 0_0]
>     New standby tasks: []
>     Existing active tasks: []
>     Existing standby tasks: [] {code}
> It would be helpful to periodically log the current assignment at a configurable interval in an manner that's machine-friendly. This can help in situations when a rebalance hasn't happened in a long while.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)