Almog Gavra created KAFKA-16038:
-----------------------------------
Summary: Periodic Logging fo 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
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)
