[
https://issues.apache.org/jira/browse/KAFKA-16038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16038:
------------------------------------
Labels: needs-kip (was: )
> 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
> Labels: needs-kip
>
> 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)
