2024-01-19 19:47:19 [2024-01-19 14:17:19,644] INFO [KafkaRaftServer nodeId=1] Kafka Server started (kafka.server.KafkaRaftServer)
2024-01-19 19:47:22 [2024-01-19 14:17:22,401] INFO [RaftManager id=1] Did not receive fetch request from the majority of the voters within 3000ms. Current fetched voters are []. (org.apache.kafka.raft.LeaderState)
2024-01-19 19:47:22 [2024-01-19 14:17:22,402] INFO [RaftManager id=1] Completed transition to ResignedState(localId=1, epoch=1, voters=[1], electionTimeoutMs=1248, unackedVoters=[], preferredSuccessors=[]) from Leader(localId=1, epoch=1, epochStartOffset=0, highWatermark=Optional[LogOffsetMetadata(offset=13, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=944)])], voterStates={1=ReplicaState(nodeId=1, endOffset=Optional[LogOffsetMetadata(offset=13, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=944)])], lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) (org.apache.kafka.raft.QuorumState)
2024-01-19 19:47:23 [2024-01-19 14:17:23,645] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:23 [2024-01-19 14:17:23,646] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:23 [2024-01-19 14:17:23,654] INFO [RaftManager id=1] Completed transition to CandidateState(localId=1, epoch=2, retries=1, voteStates={1=GRANTED}, highWatermark=Optional.empty, electionTimeoutMs=1106) from ResignedState(localId=1, epoch=1, voters=[1], electionTimeoutMs=1248, unackedVoters=[], preferredSuccessors=[]) (org.apache.kafka.raft.QuorumState)
2024-01-19 19:47:23 [2024-01-19 14:17:23,656] INFO [RaftManager id=1] Completed transition to Leader(localId=1, epoch=2, epochStartOffset=13, highWatermark=Optional.empty, voterStates={1=ReplicaState(nodeId=1, endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) from CandidateState(localId=1, epoch=2, retries=1, voteStates={1=GRANTED}, highWatermark=Optional.empty, electionTimeoutMs=1106) (org.apache.kafka.raft.QuorumState)
2024-01-19 19:47:23 [2024-01-19 14:17:23,658] INFO [RaftManager id=1] High watermark set to LogOffsetMetadata(offset=14, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1035)]) for the first time for epoch 2 based on indexOfHw 0 and voters [ReplicaState(nodeId=1, endOffset=Optional[LogOffsetMetadata(offset=14, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1035)])], lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)] (org.apache.kafka.raft.LeaderState)
2024-01-19 19:47:23 [2024-01-19 14:17:23,695] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:26 [2024-01-19 14:17:26,660] INFO [RaftManager id=1] Did not receive fetch request from the majority of the voters within 3000ms. Current fetched voters are []. (org.apache.kafka.raft.LeaderState)
2024-01-19 19:47:26 [2024-01-19 14:17:26,662] INFO [RaftManager id=1] Completed transition to ResignedState(localId=1, epoch=2, voters=[1], electionTimeoutMs=1773, unackedVoters=[], preferredSuccessors=[]) from Leader(localId=1, epoch=2, epochStartOffset=13, highWatermark=Optional[LogOffsetMetadata(offset=19, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1395)])], voterStates={1=ReplicaState(nodeId=1, endOffset=Optional[LogOffsetMetadata(offset=19, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1395)])], lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) (org.apache.kafka.raft.QuorumState)
2024-01-19 19:47:27 [2024-01-19 14:17:27,716] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:27 [2024-01-19 14:17:27,717] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:27 [2024-01-19 14:17:27,768] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:27 [2024-01-19 14:17:27,771] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:27 [2024-01-19 14:17:27,771] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:27 [2024-01-19 14:17:27,826] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:27 [2024-01-19 14:17:27,831] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:27 [2024-01-19 14:17:27,831] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:27 [2024-01-19 14:17:27,882] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:27 [2024-01-19 14:17:27,886] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:27 [2024-01-19 14:17:27,886] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:27 [2024-01-19 14:17:27,941] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:27 [2024-01-19 14:17:27,948] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:27 [2024-01-19 14:17:27,948] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,002] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,007] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:28 [2024-01-19 14:17:28,008] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,059] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,061] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:28 [2024-01-19 14:17:28,062] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,117] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,122] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:28 [2024-01-19 14:17:28,122] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,175] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,181] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:28 [2024-01-19 14:17:28,181] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,238] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,245] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:28 [2024-01-19 14:17:28,246] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,299] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,303] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:28 [2024-01-19 14:17:28,303] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,354] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,362] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:28 [2024-01-19 14:17:28,362] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,419] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,427] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:28 [2024-01-19 14:17:28,427] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:28 [2024-01-19 14:17:28,437] INFO [RaftManager id=1] Completed transition to CandidateState(localId=1, epoch=3, retries=1, voteStates={1=GRANTED}, highWatermark=Optional.empty, electionTimeoutMs=1572) from ResignedState(localId=1, epoch=2, voters=[1], electionTimeoutMs=1773, unackedVoters=[], preferredSuccessors=[]) (org.apache.kafka.raft.QuorumState)
2024-01-19 19:47:28 [2024-01-19 14:17:28,438] INFO [RaftManager id=1] Completed transition to Leader(localId=1, epoch=3, epochStartOffset=19, highWatermark=Optional.empty, voterStates={1=ReplicaState(nodeId=1, endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) from CandidateState(localId=1, epoch=3, retries=1, voteStates={1=GRANTED}, highWatermark=Optional.empty, electionTimeoutMs=1572) (org.apache.kafka.raft.QuorumState)
2024-01-19 19:47:28 [2024-01-19 14:17:28,440] INFO [RaftManager id=1] High watermark set to LogOffsetMetadata(offset=20, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1486)]) for the first time for epoch 3 based on indexOfHw 0 and voters [ReplicaState(nodeId=1, endOffset=Optional[LogOffsetMetadata(offset=20, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1486)])], lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)] (org.apache.kafka.raft.LeaderState)
2024-01-19 19:47:28 [2024-01-19 14:17:28,480] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:31 [2024-01-19 14:17:31,443] INFO [RaftManager id=1] Did not receive fetch request from the majority of the voters within 3000ms. Current fetched voters are []. (org.apache.kafka.raft.LeaderState)
2024-01-19 19:47:31 [2024-01-19 14:17:31,444] INFO [RaftManager id=1] Completed transition to ResignedState(localId=1, epoch=3, voters=[1], electionTimeoutMs=1161, unackedVoters=[], preferredSuccessors=[]) from Leader(localId=1, epoch=3, epochStartOffset=19, highWatermark=Optional[LogOffsetMetadata(offset=25, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1846)])], voterStates={1=ReplicaState(nodeId=1, endOffset=Optional[LogOffsetMetadata(offset=25, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1846)])], lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) (org.apache.kafka.raft.QuorumState)
2024-01-19 19:47:32 [2024-01-19 14:17:32,493] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:32 [2024-01-19 14:17:32,494] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:32 [2024-01-19 14:17:32,546] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:32 [2024-01-19 14:17:32,553] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:32 [2024-01-19 14:17:32,553] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:32 [2024-01-19 14:17:32,608] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:32 [2024-01-19 14:17:32,612] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:32 [2024-01-19 14:17:32,612] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:32 [2024-01-19 14:17:32,615] INFO [RaftManager id=1] Completed transition to CandidateState(localId=1, epoch=4, retries=1, voteStates={1=GRANTED}, highWatermark=Optional.empty, electionTimeoutMs=1133) from ResignedState(localId=1, epoch=3, voters=[1], electionTimeoutMs=1161, unackedVoters=[], preferredSuccessors=[]) (org.apache.kafka.raft.QuorumState)
2024-01-19 19:47:32 [2024-01-19 14:17:32,618] INFO [RaftManager id=1] Completed transition to Leader(localId=1, epoch=4, epochStartOffset=25, highWatermark=Optional.empty, voterStates={1=ReplicaState(nodeId=1, endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) from CandidateState(localId=1, epoch=4, retries=1, voteStates={1=GRANTED}, highWatermark=Optional.empty, electionTimeoutMs=1133) (org.apache.kafka.raft.QuorumState)
2024-01-19 19:47:32 [2024-01-19 14:17:32,620] INFO [RaftManager id=1] High watermark set to LogOffsetMetadata(offset=26, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1937)]) for the first time for epoch 4 based on indexOfHw 0 and voters [ReplicaState(nodeId=1, endOffset=Optional[LogOffsetMetadata(offset=26, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1937)])], lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)] (org.apache.kafka.raft.LeaderState)
2024-01-19 19:47:32 [2024-01-19 14:17:32,667] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:35 [2024-01-19 14:17:35,621] INFO [RaftManager id=1] Did not receive fetch request from the majority of the voters within 3000ms. Current fetched voters are []. (org.apache.kafka.raft.LeaderState)
2024-01-19 19:47:35 [2024-01-19 14:17:35,622] INFO [RaftManager id=1] Completed transition to ResignedState(localId=1, epoch=4, voters=[1], electionTimeoutMs=1436, unackedVoters=[], preferredSuccessors=[]) from Leader(localId=1, epoch=4, epochStartOffset=25, highWatermark=Optional[LogOffsetMetadata(offset=31, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=2297)])], voterStates={1=ReplicaState(nodeId=1, endOffset=Optional[LogOffsetMetadata(offset=31, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=2297)])], lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) (org.apache.kafka.raft.QuorumState)
2024-01-19 19:47:36 [2024-01-19 14:17:36,680] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:36 [2024-01-19 14:17:36,681] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:36 [2024-01-19 14:17:36,735] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:36 [2024-01-19 14:17:36,737] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:36 [2024-01-19 14:17:36,737] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:36 [2024-01-19 14:17:36,791] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:36 [2024-01-19 14:17:36,797] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:36 [2024-01-19 14:17:36,798] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:36 [2024-01-19 14:17:36,848] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:36 [2024-01-19 14:17:36,850] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:36 [2024-01-19 14:17:36,850] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:36 [2024-01-19 14:17:36,905] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:36 [2024-01-19 14:17:36,907] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:36 [2024-01-19 14:17:36,907] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:36 [2024-01-19 14:17:36,962] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:36 [2024-01-19 14:17:36,967] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:36 [2024-01-19 14:17:36,968] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:37 [2024-01-19 14:17:37,023] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:37 [2024-01-19 14:17:37,029] INFO [NodeToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 1 (org.apache.kafka.clients.NetworkClient)
2024-01-19 19:47:37 [2024-01-19 14:17:37,029] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node localhost:9093 (id: 1 rack: null) (kafka.server.NodeToControllerRequestThread)
2024-01-19 19:47:37 [2024-01-19 14:17:37,063] INFO [RaftManager id=1] Completed transition to CandidateState(localId=1, epoch=5, retries=1, voteStates={1=GRANTED}, highWatermark=Optional.empty, electionTimeoutMs=1622) from ResignedState(localId=1, epoch=4, voters=[1], electionTimeoutMs=1436, unackedVoters=[], preferredSuccessors=[]) (org.apache.kafka.raft.QuorumState)
2024-01-19 19:47:37 [2024-01-19 14:17:37,065] INFO [RaftManager id=1] Completed transition to Leader(localId=1, epoch=5, epochStartOffset=31, highWatermark=Optional.empty, voterStates={1=ReplicaState(nodeId=1, endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) from CandidateState(localId=1, epoch=5, retries=1, voteStates={1=GRANTED}, highWatermark=Optional.empty, electionTimeoutMs=1622) (org.apache.kafka.raft.QuorumState)