[ https://issues.apache.org/jira/browse/KAFKA-16038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Almog Gavra updated KAFKA-16038: -------------------------------- Summary: Periodic Logging of Current Assignment (was: Periodic Logging fo Current Assignment) > 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)