Luke Chen created KAFKA-19219:
---------------------------------
Summary: improve KRaft migration log
Key: KAFKA-19219
URL: https://issues.apache.org/jira/browse/KAFKA-19219
Project: Kafka
Issue Type: Improvement
Affects Versions: 3.9.1
Reporter: Luke Chen
During the KRaft migration (in DUAL_WRITE mode), even if all the brokers are
entering KRaft mode, the logs are still showing
`Sending incremental metadata RPCs to brokers for delta.` , and then after some
lines, the `Not sending request LeaderAndIsr with ... to broker 0, since it is
offline.` appeared. It'll confuse users if not read clearly. We can improve the
logs here.
{code:java}
[2025-04-30 17:30:11,705] TRACE [KRaftMigrationDriver id=1] Sending incremental
metadata RPCs to brokers for delta.
(org.apache.kafka.metadata.migration.KRaftMigrationDriver)
[2025-04-30 17:30:11,705] INFO [Controller id=1 epoch=4] Sending UpdateMetadata
request to brokers HashSet() for 0 partitions (state.change.logger)
[2025-04-30 17:30:11,706] INFO [Controller id=1 epoch=4] Sending LeaderAndIsr
request to broker 0 with 0 become-leader and 1 become-follower partitions
(state.change.logger)
[2025-04-30 17:30:11,706] WARN [Channel manager on controller 1]: Not sending
request LeaderAndIsr with controllerId=1, controllerEpoch=4, brokerEpoch=230 to
broker 0, since it is offline. (kafka.controller.ControllerChannelManager)
[2025-04-30 17:30:11,706] INFO [Controller id=1 epoch=4] Sending LeaderAndIsr
request to broker 4 with 1 become-leader and 0 become-follower partitions
(state.change.logger)
[2025-04-30 17:30:11,706] WARN [Channel manager on controller 1]: Not sending
request LeaderAndIsr with controllerId=1, controllerEpoch=4, brokerEpoch=316 to
broker 4, since it is offline. (kafka.controller.ControllerChannelManager)
[2025-04-30 17:30:11,706] INFO [Controller id=1 epoch=4] Sending UpdateMetadata
request to brokers HashSet(0, 4) for 1 partitions (state.change.logger)
[2025-04-30 17:30:11,706] WARN [Channel manager on controller 1]: Not sending
request UpdateMetadata with controllerId=1, controllerEpoch=4, brokerEpoch=230
to broker 0, since it is offline. (kafka.controller.ControllerChannelManager)
[2025-04-30 17:30:11,706] WARN [Channel manager on controller 1]: Not sending
request UpdateMetadata with controllerId=1, controllerEpoch=4, brokerEpoch=316
to broker 4, since it is offline. (kafka.controller.ControllerChannelManager)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
