Strimzi
Replies: 3 comments 2 replies
-
|
It is hard to say what the problem is without observing your system. Was the topic in-sync with a leader during the rolling update? You seem to use It could be also an issue with getting metadata in the client. Ot it could be also an issue with loadbalancer healthchecks which need more time to let the connections in (although I have not seen this with MetalLB really in the past, I don't think it does any health checking, at least not in my installation). |
Beta Was this translation helpful? Give feedback.
-
|
Thank for the reply. I had tried creating the topics with min.insync.replicas=2 and min.insync.replicas=3. But still I could see the disturbances in producing messages while rolling upgrade. I had tried with different combinations mentioned below. Few doubts regarding strimzi kafka features. --> Is strimzi kafka supports zero down time upgrades? ---->bin/kafka-topics.sh --bootstrap-server 182.65.15.152:30058 --create --topic topic-nov-22 --partitions 1 --replication-factor 3 --config min.insync.replicas=2 --command-config /home/ethonag/rooling-upgrades/kafka.client.txt --->bin/kafka-topics.sh --bootstrap-server 182.65.15.152:30058 --create --topic topic-nov-22 --partitions 3 --replication-factor 3 --config min.insync.replicas=3 --command-config /home/ethonag/rooling-upgrades/kafka.client.txt Reduced acks=1 while producing messages: bin/kafka-producer-perf-test.sh --topic topic-nov-22 --num-records 100000000 --record-size 1 --throughput -1 --producer-props acks=2 --producer.config /home/ethonag/rooling-upgrades/kafka.client.txt Errors executing above command: Kafka pod logs: 2021-11-22 07:06:24,896 INFO [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Starting (kafka.server.ReplicaFetcherThread) [ReplicaFetcherThread-0-2] |
Beta Was this translation helpful? Give feedback.
-
|
I don't see anything unexpected. But maybe I just missed it > you didn't used any formatting so the logs are very hard to read. |
Beta Was this translation helpful? Give feedback.
-
|
Sorry for inconvenience. I will restate my issue. I had tried creating the topics with min.insync.replicas=2 and min.insync.replicas=3. But still I could see the disturbances in producing messages while rolling upgrade. Is it common issue or any data loss is happening in this case. I had tried with different combinations mentioned below. Few doubts regarding strimzi kafka features. --> Is strimzi kafka supports zero down time upgrades? Scenarios I tried: ---->bin/kafka-topics.sh --bootstrap-server 182.65.15.152:30058 --create --topic topic-nov-22 --partitions 1 --replication-factor 3 --config min.insync.replicas=2 --command-config /home/ethonag/rooling-upgrades/kafka.client.txt --->bin/kafka-topics.sh --bootstrap-server 182.65.15.152:30058 --create --topic topic-nov-22 --partitions 3 --replication-factor 3 --config min.insync.replicas=3 --command-config /home/ethonag/rooling-upgrades/kafka.client.txt Reduced acks=1 while producing messages: bin/kafka-producer-perf-test.sh --topic topic-nov-22 --num-records 100000000 --record-size 1 --throughput -1 --producer-props acks=1 --producer.config /home/ethonag/rooling-upgrades/kafka.client.txt Errors while executing above command: kafka pod logs: |
Beta Was this translation helpful? Give feedback.
-
|
I'm not sure if I mentioned it before in this thread or somewhere else. But the rolling updates in general have always some disruption. The only promise is that if you have everything properly configured in the brokers, topics and clients, you should not loose messages and the unavailability and disruption should be minimal. But during the rolling update, it will always have to shutdown brokers causing disconnects, leadership changes, etc. So yes, the clients will be disconnected from the broker which is shutdown, they will not be able to reconnect immediately and instead of it will need to refresh the metadata and connect somewhere else. That is what is for example in your log above => there is nothing unexpected on it. |
Beta Was this translation helpful? Give feedback.
Uh oh!
There was an error while loading. Please reload this page.
-
Hello, I'm testing rolling upgrades for strimzi kafka with 3 replicas. While producing messages using client, upgraded kafka from 2.8.0 to 2.8.1. After sometime client stopped to produce messages due to following error and after some time its producing again. Anything wrong in kafka configuration, please suggest if any. Providing kafka configuration file below along with error and kafka logs. My concern here is
-> Is there any data loss while performing rolling upgrades.
-> Is strimzi kafka supports zero downtime upgrades (i.e while performing upgrades there will be no disturbances in producing and consuming messages in kafka).
Kafka.yaml file:
Error while producing messages using client:
bin/kafka-producer-perf-test.sh --topic test-topic-2 --num-records 1000000000 --record-size 1 --throughput -1 --producer-props acks=all --producer.config /home/ethonag/rooling-upgrades/kafka.client.txt
154483 records sent, 30410.0 records/sec (0.03 MB/sec), 1970.4 ms avg latency, 3737.0 ms max latency.
129208 records sent, 20577.8 records/sec (0.02 MB/sec), 6020.2 ms avg latency, 9672.0 ms max latency.
116325 records sent, 20007.7 records/sec (0.02 MB/sec), 11397.0 ms avg latency, 15247.0 ms max latency.
112840 records sent, 22247.6 records/sec (0.02 MB/sec), 16824.1 ms avg latency, 20156.0 ms max latency.
125546 records sent, 19746.1 records/sec (0.02 MB/sec), 22249.0 ms avg latency, 26246.0 ms max latency.
179938 records sent, 28097.8 records/sec (0.03 MB/sec), 28604.8 ms avg latency, 32158.0 ms max latency.
147420 records sent, 23292.8 records/sec (0.02 MB/sec), 34903.5 ms avg latency, 38239.0 ms max latency.
118209 records sent, 22750.0 records/sec (0.02 MB/sec), 39544.5 ms avg latency, 42961.0 ms max latency.
150666 records sent, 24285.3 records/sec (0.02 MB/sec), 45012.1 ms avg latency, 48663.0 ms max latency.
218082 records sent, 33680.6 records/sec (0.03 MB/sec), 50834.3 ms avg latency, 54425.0 ms max latency.
209139 records sent, 40625.3 records/sec (0.04 MB/sec), 56170.1 ms avg latency, 59185.0 ms max latency.
92728 records sent, 14318.7 records/sec (0.01 MB/sec), 61867.1 ms avg latency, 65614.0 ms max latency.
156520 records sent, 31104.9 records/sec (0.03 MB/sec), 66994.3 ms avg latency, 70237.0 ms max latency.
187278 records sent, 36916.6 records/sec (0.04 MB/sec), 71334.4 ms avg latency, 74763.0 ms max latency.
192555 records sent, 30166.8 records/sec (0.03 MB/sec), 76759.2 ms avg latency, 80769.0 ms max latency.
269079 records sent, 41860.5 records/sec (0.04 MB/sec), 82840.4 ms avg latency, 86572.0 ms max latency.
265655 records sent, 53131.0 records/sec (0.05 MB/sec), 87057.4 ms avg latency, 89545.0 ms max latency.
327465 records sent, 65349.2 records/sec (0.06 MB/sec), 91648.2 ms avg latency, 93858.0 ms max latency.
246970 records sent, 38432.9 records/sec (0.04 MB/sec), 90681.4 ms avg latency, 93679.0 ms max latency.
118056 records sent, 18600.3 records/sec (0.02 MB/sec), 89829.1 ms avg latency, 94212.0 ms max latency.
150865 records sent, 25006.6 records/sec (0.02 MB/sec), 89076.8 ms avg latency, 95797.0 ms max latency.
211842 records sent, 34206.7 records/sec (0.03 MB/sec), 88667.9 ms avg latency, 95580.0 ms max latency.
299582 records sent, 47409.7 records/sec (0.05 MB/sec), 84649.5 ms avg latency, 93747.0 ms max latency.
257944 records sent, 48522.2 records/sec (0.05 MB/sec), 78958.5 ms avg latency, 87116.0 ms max latency.
163167 records sent, 25631.0 records/sec (0.02 MB/sec), 78994.5 ms avg latency, 84318.0 ms max latency.
203485 records sent, 40462.3 records/sec (0.04 MB/sec), 78737.2 ms avg latency, 85662.0 ms max latency.
134465 records sent, 25428.3 records/sec (0.02 MB/sec), 76864.4 ms avg latency, 85583.0 ms max latency.
177723 records sent, 29201.9 records/sec (0.03 MB/sec), 77514.2 ms avg latency, 84736.0 ms max latency.
176297 records sent, 34159.5 records/sec (0.03 MB/sec), 78392.3 ms avg latency, 85169.0 ms max latency.
174483 records sent, 33451.5 records/sec (0.03 MB/sec), 77825.4 ms avg latency, 85216.0 ms max latency.
126994 records sent, 23701.8 records/sec (0.02 MB/sec), 80187.9 ms avg latency, 86852.0 ms max latency.
152807 records sent, 29117.2 records/sec (0.03 MB/sec), 82405.5 ms avg latency, 88913.0 ms max latency.
165451 records sent, 31616.9 records/sec (0.03 MB/sec), 84166.3 ms avg latency, 89431.0 ms max latency.
[2021-11-18 14:19:56,261] WARN [Producer clientId=producer-1] Got error produce response with correlation id 3274 on topic-partition test-topic-2-2, retrying (2147483646 attempts left). Error: NOT_LEADER_OR_FOLLOWER (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:19:56,262] WARN [Producer clientId=producer-1] Received invalid metadata error in produce request on partition test-topic-2-2 due to org.apache.kafka.common.errors.NotLeaderOrFollowerException: For requests intended only for the leader, this error indicates that the broker is not the current leader. For requests intended for any replica, this error indicates that the broker is not a replica of the topic partition.. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:19:57,699] WARN [Producer clientId=producer-1] Got error produce response with correlation id 3277 on topic-partition test-topic-2-2, retrying (2147483646 attempts left). Error: NOT_LEADER_OR_FOLLOWER (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:19:57,699] WARN [Producer clientId=producer-1] Received invalid metadata error in produce request on partition test-topic-2-2 due to org.apache.kafka.common.errors.NotLeaderOrFollowerException: For requests intended only for the leader, this error indicates that the broker is not the current leader. For requests intended for any replica, this error indicates that the broker is not a replica of the topic partition.. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:19:57,700] WARN [Producer clientId=producer-1] Got error produce response with correlation id 3280 on topic-partition test-topic-2-2, retrying (2147483646 attempts left). Error: NOT_LEADER_OR_FOLLOWER (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:19:57,700] WARN [Producer clientId=producer-1] Received invalid metadata error in produce request on partition test-topic-2-2 due to org.apache.kafka.common.errors.NotLeaderOrFollowerException: For requests intended only for the leader, this error indicates that the broker is not the current leader. For requests intended for any replica, this error indicates that the broker is not a replica of the topic partition.. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:19:57,701] WARN [Producer clientId=producer-1] Got error produce response with correlation id 3283 on topic-partition test-topic-2-2, retrying (2147483646 attempts left). Error: NOT_LEADER_OR_FOLLOWER (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:19:57,701] WARN [Producer clientId=producer-1] Received invalid metadata error in produce request on partition test-topic-2-2 due to org.apache.kafka.common.errors.NotLeaderOrFollowerException: For requests intended only for the leader, this error indicates that the broker is not the current leader. For requests intended for any replica, this error indicates that the broker is not a replica of the topic partition.. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:19:57,701] WARN [Producer clientId=producer-1] Got error produce response with correlation id 3287 on topic-partition test-topic-2-2, retrying (2147483646 attempts left). Error: NOT_LEADER_OR_FOLLOWER (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:19:57,702] WARN [Producer clientId=producer-1] Received invalid metadata error in produce request on partition test-topic-2-2 due to org.apache.kafka.common.errors.NotLeaderOrFollowerException: For requests intended only for the leader, this error indicates that the broker is not the current leader. For requests intended for any replica, this error indicates that the broker is not a replica of the topic partition.. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender)
59802 records sent, 11007.2 records/sec (0.01 MB/sec), 86328.9 ms avg latency, 91911.0 ms max latency.
87360 records sent, 16936.8 records/sec (0.02 MB/sec), 91451.3 ms avg latency, 96711.0 ms max latency.
170587 records sent, 28694.2 records/sec (0.03 MB/sec), 93664.4 ms avg latency, 99772.0 ms max latency.
112840 records sent, 21286.5 records/sec (0.02 MB/sec), 95776.5 ms avg latency, 103013.0 ms max latency.
141739 records sent, 28050.5 records/sec (0.03 MB/sec), 99066.2 ms avg latency, 106383.0 ms max latency.
130916 records sent, 24438.3 records/sec (0.02 MB/sec), 98684.8 ms avg latency, 106075.0 ms max latency.
196275 records sent, 36126.4 records/sec (0.03 MB/sec), 98750.8 ms avg latency, 106689.0 ms max latency.
212718 records sent, 33926.3 records/sec (0.03 MB/sec), 98201.4 ms avg latency, 104833.0 ms max latency.
334068 records sent, 62186.9 records/sec (0.06 MB/sec), 97391.2 ms avg latency, 104490.0 ms max latency.
486549 records sent, 87195.2 records/sec (0.08 MB/sec), 91209.6 ms avg latency, 101795.0 ms max latency.
339592 records sent, 64037.7 records/sec (0.06 MB/sec), 83719.7 ms avg latency, 95930.0 ms max latency.
368611 records sent, 65589.1 records/sec (0.06 MB/sec), 78115.5 ms avg latency, 91227.0 ms max latency.
273994 records sent, 51415.7 records/sec (0.05 MB/sec), 71564.3 ms avg latency, 85562.0 ms max latency.
59657 records sent, 9525.3 records/sec (0.01 MB/sec), 70821.6 ms avg latency, 85192.0 ms max latency.
130519 records sent, 25779.0 records/sec (0.02 MB/sec), 71682.3 ms avg latency, 86550.0 ms max latency.
130863 records sent, 25785.8 records/sec (0.02 MB/sec), 71258.5 ms avg latency, 87788.0 ms max latency.
206985 records sent, 33476.5 records/sec (0.03 MB/sec), 69570.9 ms avg latency, 88940.0 ms max latency.
192363 records sent, 37629.7 records/sec (0.04 MB/sec), 66886.3 ms avg latency, 85586.0 ms max latency.
350148 records sent, 64662.6 records/sec (0.06 MB/sec), 64662.2 ms avg latency, 83559.0 ms max latency.
187162 records sent, 35280.3 records/sec (0.03 MB/sec), 62234.9 ms avg latency, 76114.0 ms max latency.
[2021-11-18 14:21:47,099] WARN [Producer clientId=producer-1] Got error produce response with correlation id 4887 on topic-partition test-topic-2-1, retrying (2147483646 attempts left). Error: NETWORK_EXCEPTION. Error Message: Disconnected from node 1 (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:21:47,099] WARN [Producer clientId=producer-1] Received invalid metadata error in produce request on partition test-topic-2-1 due to org.apache.kafka.common.errors.NetworkException: Disconnected from node 1. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:21:47,099] WARN [Producer clientId=producer-1] Got error produce response with correlation id 4889 on topic-partition test-topic-2-1, retrying (2147483646 attempts left). Error: NETWORK_EXCEPTION. Error Message: Disconnected from node 1 (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:21:47,099] WARN [Producer clientId=producer-1] Received invalid metadata error in produce request on partition test-topic-2-1 due to org.apache.kafka.common.errors.NetworkException: Disconnected from node 1. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:21:47,099] WARN [Producer clientId=producer-1] Got error produce response with correlation id 4891 on topic-partition test-topic-2-1, retrying (2147483646 attempts left). Error: NETWORK_EXCEPTION. Error Message: Disconnected from node 1 (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:21:47,099] WARN [Producer clientId=producer-1] Received invalid metadata error in produce request on partition test-topic-2-1 due to org.apache.kafka.common.errors.NetworkException: Disconnected from node 1. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:21:47,099] WARN [Producer clientId=producer-1] Got error produce response with correlation id 4893 on topic-partition test-topic-2-1, retrying (2147483646 attempts left). Error: NETWORK_EXCEPTION. Error Message: Disconnected from node 1 (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:21:47,099] WARN [Producer clientId=producer-1] Received invalid metadata error in produce request on partition test-topic-2-1 due to org.apache.kafka.common.errors.NetworkException: Disconnected from node 1. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:21:47,099] WARN [Producer clientId=producer-1] Got error produce response with correlation id 4895 on topic-partition test-topic-2-1, retrying (2147483646 attempts left). Error: NETWORK_EXCEPTION. Error Message: Disconnected from node 1 (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:21:47,100] WARN [Producer clientId=producer-1] Received invalid metadata error in produce request on partition test-topic-2-1 due to org.apache.kafka.common.errors.NetworkException: Disconnected from node 1. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:21:49,767] WARN [Producer clientId=producer-1] Connection to node 1 (/153.88.15.141:30058) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
74478 records sent, 13973.4 records/sec (0.01 MB/sec), 65561.0 ms avg latency, 75802.0 ms max latency.
189173 records sent, 29960.9 records/sec (0.03 MB/sec), 70128.6 ms avg latency, 78450.0 ms max latency.
796352 records sent, 147801.0 records/sec (0.14 MB/sec), 67931.1 ms avg latency, 77108.0 ms max latency.
[2021-11-18 14:22:07,510] WARN [Producer clientId=producer-1] Got error produce response with correlation id 5155 on topic-partition test-topic-2-2, retrying (2147483646 attempts left). Error: NOT_LEADER_OR_FOLLOWER (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:22:07,510] WARN [Producer clientId=producer-1] Received invalid metadata error in produce request on partition test-topic-2-2 due to org.apache.kafka.common.errors.NotLeaderOrFollowerException: For requests intended only for the leader, this error indicates that the broker is not the current leader. For requests intended for any replica, this error indicates that the broker is not a replica of the topic partition.. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:22:07,521] WARN [Producer clientId=producer-1] Got error produce response with correlation id 5156 on topic-partition test-topic-2-2, retrying (2147483646 attempts left). Error: NOT_LEADER_OR_FOLLOWER (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:22:07,521] WARN [Producer clientId=producer-1] Received invalid metadata error in produce request on partition test-topic-2-2 due to org.apache.kafka.common.errors.NotLeaderOrFollowerException: For requests intended only for the leader, this error indicates that the broker is not the current leader. For requests intended for any replica, this error indicates that the broker is not a replica of the topic partition.. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:22:07,531] WARN [Producer clientId=producer-1] Got error produce response with correlation id 5157 on topic-partition test-topic-2-2, retrying (2147483646 attempts left). Error: NOT_LEADER_OR_FOLLOWER (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:22:07,531] WARN [Producer clientId=producer-1] Received invalid metadata error in produce request on partition test-topic-2-2 due to org.apache.kafka.common.errors.NotLeaderOrFollowerException: For requests intended only for the leader, this error indicates that the broker is not the current leader. For requests intended for any replica, this error indicates that the broker is not a replica of the topic partition.. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:22:07,558] WARN [Producer clientId=producer-1] Got error produce response with correlation id 5158 on topic-partition test-topic-2-2, retrying (2147483646 attempts left). Error: NOT_LEADER_OR_FOLLOWER (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:22:07,558] WARN [Producer clientId=producer-1] Received invalid metadata error in produce request on partition test-topic-2-2 due to org.apache.kafka.common.errors.NotLeaderOrFollowerException: For requests intended only for the leader, this error indicates that the broker is not the current leader. For requests intended for any replica, this error indicates that the broker is not a replica of the topic partition.. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender)
417691 records sent, 68835.0 records/sec (0.07 MB/sec), 61255.9 ms avg latency, 71524.0 ms max latency.
[2021-11-18 14:22:08,905] WARN [Producer clientId=producer-1] Got error produce response with correlation id 5159 on topic-partition test-topic-2-2, retrying (2147483646 attempts left). Error: NOT_LEADER_OR_FOLLOWER (org.apache.kafka.clients.producer.internals.Sender)
[2021-11-18 14:22:08,905] WARN [Producer clientId=producer-1] Received invalid metadata error in produce request on partition test-topic-2-2 due to org.apache.kafka.common.errors.NotLeaderOrFollowerException: For requests intended only for the leader, this error indicates that the broker is not the current leader. For requests intended for any replica, this error indicates that the broker is not a replica of the topic partition.. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender)
Kafka pod logs:
2021-11-18 13:28:47,994 INFO [Controller id=0 epoch=2] Changed partition __consumer_offsets-35 from OnlinePartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=4, isr=List(0, 1, 2), zkVersion=7) (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 INFO [Controller id=0 epoch=2] Changed partition __consumer_offsets-41 from OnlinePartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=4, isr=List(0, 1, 2), zkVersion=7) (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 INFO [Controller id=0 epoch=2] Changed partition __consumer_offsets-23 from OnlinePartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=4, isr=List(0, 1, 2), zkVersion=7) (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 INFO [Controller id=0 epoch=2] Changed partition __consumer_offsets-2 from OnlinePartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=4, isr=List(0, 1, 2), zkVersion=7) (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 INFO [Controller id=0 epoch=2] Changed partition __consumer_offsets-14 from OnlinePartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=4, isr=List(0, 1, 2), zkVersion=7) (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 INFO [Controller id=0 epoch=2] Changed partition __consumer_offsets-20 from OnlinePartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=4, isr=List(0, 1, 2), zkVersion=7) (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 INFO [Controller id=0 epoch=2] Changed partition __consumer_offsets-44 from OnlinePartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=4, isr=List(0, 1, 2), zkVersion=7) (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 INFO [Controller id=0 epoch=2] Changed partition __consumer_offsets-5 from OnlinePartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=4, isr=List(0, 1, 2), zkVersion=7) (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 INFO [Controller id=0 epoch=2] Changed partition __consumer_offsets-26 from OnlinePartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=4, isr=List(0, 1, 2), zkVersion=7) (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=47, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-47 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=14, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-14 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=11, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-11 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=44, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-44 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=41, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-41 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=23, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-23 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=20, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-20 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=17, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-17 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=32, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-32 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='test-topic-1', partitionIndex=2, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition test-topic-1-2 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=29, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-29 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=26, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-26 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=8, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-8 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,994 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=5, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-5 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=38, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-38 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=35, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-35 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='test-topic-2', partitionIndex=0, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition test-topic-2-0 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=2, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition __consumer_offsets-2 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='test-topic-3', partitionIndex=2, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 0 for partition test-topic-3-2 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 INFO [Controller id=0 epoch=2] Sending LeaderAndIsr request to broker 0 with 0 become-leader and 19 become-follower partitions (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=47, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-47 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=14, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-14 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=11, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-11 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=44, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-44 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=41, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-41 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=23, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-23 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=20, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-20 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=17, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-17 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=32, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-32 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='test-topic-1', partitionIndex=2, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition test-topic-1-2 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=29, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-29 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=26, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-26 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=8, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-8 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=5, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-5 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=38, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-38 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=35, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-35 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='test-topic-2', partitionIndex=0, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition test-topic-2-0 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=2, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition __consumer_offsets-2 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-follower LeaderAndIsr request LeaderAndIsrPartitionState(topicName='test-topic-3', partitionIndex=2, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 1 for partition test-topic-3-2 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 INFO [Controller id=0 epoch=2] Sending LeaderAndIsr request to broker 1 with 0 become-leader and 19 become-follower partitions (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=47, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-47 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=14, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-14 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=11, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-11 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=44, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-44 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=41, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-41 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=23, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-23 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=20, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-20 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=17, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-17 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=32, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-32 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='test-topic-1', partitionIndex=2, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition test-topic-1-2 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=29, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-29 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=26, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-26 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=8, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-8 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=5, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-5 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=38, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-38 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,995 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=35, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-35 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,996 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='test-topic-2', partitionIndex=0, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition test-topic-2-0 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,996 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=2, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition __consumer_offsets-2 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,996 TRACE [Controller id=0 epoch=2] Sending become-leader LeaderAndIsr request LeaderAndIsrPartitionState(topicName='test-topic-3', partitionIndex=2, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) to broker 2 for partition test-topic-3-2 (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,996 INFO [Controller id=0 epoch=2] Sending LeaderAndIsr request to broker 2 with 19 become-leader and 0 become-follower partitions (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,996 INFO [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 for 19 partitions (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 INFO [Controller id=0 epoch=2] Sending UpdateMetadata request to brokers HashSet(0, 1, 2) for 19 partitions (state.change.logger) [controller-event-thread]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='test-topic-3', partitionIndex=2, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='test-topic-1', partitionIndex=2, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=47, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=14, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=11, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=44, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=41, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=23, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=20, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=17, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=32, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=29, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=26, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=8, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=5, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=38, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=35, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=2, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='test-topic-2', partitionIndex=0, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=false) correlation id 21 from controller 0 epoch 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 INFO [Controller id=0] Partition __consumer_offsets-8 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,996 INFO [Controller id=0] Partition __consumer_offsets-47 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-35 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-5 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-20 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-41 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-29 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,996 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-44 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-14 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-2 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-23 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-38 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-8 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-11 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-26 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-47 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition test-topic-3-2 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition test-topic-2-0 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition __consumer_offsets-38 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition __consumer_offsets-17 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition __consumer_offsets-11 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition test-topic-1-2 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition __consumer_offsets-29 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition __consumer_offsets-32 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition test-topic-3-2 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition __consumer_offsets-35 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition __consumer_offsets-41 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition __consumer_offsets-23 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition __consumer_offsets-2 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition __consumer_offsets-14 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition __consumer_offsets-20 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition __consumer_offsets-44 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition __consumer_offsets-5 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 INFO [Controller id=0] Partition __consumer_offsets-26 completed preferred replica leader election. New leader is 2 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:28:47,997 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-17 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition test-topic-2-0 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition __consumer_offsets-32 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 21 from controller 0 epoch 2 starting the become-follower transition for partition test-topic-1-2 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 INFO [Broker id=0] Follower __consumer_offsets-35 starts at leader epoch 4 from offset 0 with high watermark 0. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 INFO [Broker id=0] Follower __consumer_offsets-5 starts at leader epoch 4 from offset 0 with high watermark 0. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,997 INFO [Broker id=0] Follower __consumer_offsets-20 starts at leader epoch 4 from offset 0 with high watermark 0. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,998 INFO [Broker id=0] Follower __consumer_offsets-41 starts at leader epoch 4 from offset 0 with high watermark 0. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,998 INFO [Broker id=0] Follower __consumer_offsets-29 starts at leader epoch 4 from offset 0 with high watermark 0. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,998 INFO [Broker id=0] Follower __consumer_offsets-44 starts at leader epoch 4 from offset 4 with high watermark 4. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,998 INFO [Broker id=0] Follower __consumer_offsets-14 starts at leader epoch 4 from offset 0 with high watermark 0. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,998 INFO [Broker id=0] Follower __consumer_offsets-2 starts at leader epoch 4 from offset 0 with high watermark 0. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,998 INFO [Broker id=0] Follower __consumer_offsets-23 starts at leader epoch 4 from offset 0 with high watermark 0. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,998 INFO [Broker id=0] Follower __consumer_offsets-38 starts at leader epoch 4 from offset 0 with high watermark 0. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,998 INFO [Broker id=0] Follower __consumer_offsets-8 starts at leader epoch 4 from offset 0 with high watermark 0. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,998 INFO [Broker id=0] Follower __consumer_offsets-11 starts at leader epoch 4 from offset 0 with high watermark 0. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,998 INFO [Broker id=0] Follower __consumer_offsets-26 starts at leader epoch 4 from offset 0 with high watermark 0. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,998 INFO [Broker id=0] Follower __consumer_offsets-47 starts at leader epoch 4 from offset 0 with high watermark 0. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,998 INFO [Broker id=0] Follower test-topic-3-2 starts at leader epoch 4 from offset 4573633 with high watermark 4573633. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,998 INFO [Broker id=0] Follower __consumer_offsets-17 starts at leader epoch 4 from offset 0 with high watermark 0. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:47,998 INFO [Broker id=0] Follower test-topic-2-0 starts at leader epoch 4 from offset 8720474 with high watermark 8720474. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,000 INFO [Broker id=0] Follower __consumer_offsets-32 starts at leader epoch 4 from offset 0 with high watermark 0. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,000 INFO [Broker id=0] Follower test-topic-1-2 starts at leader epoch 4 from offset 935292 with high watermark 935292. Previous leader epoch was 3. (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,001 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions HashSet(__consumer_offsets-47, __consumer_offsets-14, __consumer_offsets-11, __consumer_offsets-44, __consumer_offsets-41, __consumer_offsets-23, __consumer_offsets-20, __consumer_offsets-17, __consumer_offsets-32, test-topic-1-2, __consumer_offsets-29, __consumer_offsets-26, __consumer_offsets-8, __consumer_offsets-5, __consumer_offsets-38, __consumer_offsets-35, test-topic-2-0, __consumer_offsets-2, test-topic-3-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,001 INFO [Broker id=0] Stopped fetchers as part of become-follower request from controller 0 epoch 2 with correlation id 21 for 19 partitions (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,494 TRACE [Controller id=0 epoch=2] Received response LeaderAndIsrResponseData(errorCode=0, partitionErrors=[], topics=[LeaderAndIsrTopicError(topicId=WQfOhFctS1uL8n4wUAgQbw, partitionErrors=[LeaderAndIsrPartitionError(topicName='', partitionIndex=2, errorCode=0)]), LeaderAndIsrTopicError(topicId=yYd9hdvQQqSPLkTgoXWQTg, partitionErrors=[LeaderAndIsrPartitionError(topicName='', partitionIndex=2, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=35, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=38, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=5, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=8, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=26, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=29, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=32, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=17, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=20, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=23, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=41, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=44, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=11, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=14, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=47, errorCode=0)]), LeaderAndIsrTopicError(topicId=0qhjgX--QlCRfVMPdOj9Ew, partitionErrors=[LeaderAndIsrPartitionError(topicName='', partitionIndex=2, errorCode=0)]), LeaderAndIsrTopicError(topicId=OdkjQMwvR0mNNX853I4w6g, partitionErrors=[LeaderAndIsrPartitionError(topicName='', partitionIndex=0, errorCode=0)])]) for request LEADER_AND_ISR with correlation id 14 sent to broker my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091 (id: 2 rack: null) (state.change.logger) [Controller-0-to-broker-2-send-thread]
2021-11-18 13:28:48,500 TRACE [Controller id=0 epoch=2] Received response UpdateMetadataResponseData(errorCode=0) for request UPDATE_METADATA with correlation id 15 sent to broker my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091 (id: 2 rack: null) (state.change.logger) [Controller-0-to-broker-2-send-thread]
2021-11-18 13:28:48,599 INFO [ReplicaFetcherManager on broker 0] Added fetcher to broker 2 for partitions HashMap(__consumer_offsets-8 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,0), __consumer_offsets-47 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,0), test-topic-2-0 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,8720474), __consumer_offsets-38 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,0), __consumer_offsets-17 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,0), __consumer_offsets-11 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,0), test-topic-1-2 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,935292), __consumer_offsets-29 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,0), __consumer_offsets-32 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,0), test-topic-3-2 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,4573633), __consumer_offsets-35 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,0), __consumer_offsets-41 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,0), __consumer_offsets-23 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,0), __consumer_offsets-2 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,0), __consumer_offsets-14 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,0), __consumer_offsets-20 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,0), __consumer_offsets-44 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,4), __consumer_offsets-5 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,0), __consumer_offsets-26 -> InitialFetchState(BrokerEndPoint(id=2, host=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091),4,0)) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-35 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-5 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-20 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-41 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-29 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-44 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-14 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-2 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-23 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-38 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-8 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-11 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-26 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-47 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition test-topic-3-2 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-17 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition test-topic-2-0 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition __consumer_offsets-32 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,599 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 21 from controller 0 epoch 2 for the become-follower transition for partition test-topic-1-2 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Starting (kafka.server.ReplicaFetcherThread) [ReplicaFetcherThread-0-2]
2021-11-18 13:28:48,600 INFO [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-32 to local high watermark 0 (kafka.server.ReplicaFetcherThread) [ReplicaFetcherThread-0-2]
2021-11-18 13:28:48,600 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 35 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-35 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 5 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-5 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 20 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-20 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 41 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-41 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 29 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-29 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 44 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-44 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 14 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-14 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 2 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-2 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 23 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-23 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,600 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 38 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-38 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,601 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 8 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-8 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,601 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 11 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-11 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,601 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 26 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-26 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,601 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 47 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-47 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,601 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 17 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-17 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,601 INFO [GroupCoordinator 0]: Resigned as the group coordinator for partition 32 in epoch Some(4) (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Scheduling unloading of offsets and group metadata from __consumer_offsets-32 (kafka.coordinator.group.GroupMetadataManager) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,601 INFO [Broker id=0] Finished LeaderAndIsr request in 605ms correlationId 21 from controller 0 for 19 partitions (state.change.logger) [data-plane-kafka-request-handler-6]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-35 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-5 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-20 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-41 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-29 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-44 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-14 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-2 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-23 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-38 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-8 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-11 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-26 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-47 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-17 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,601 INFO [GroupMetadataManager brokerId=0] Finished unloading __consumer_offsets-32 for coordinator epoch Some(4). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [group-metadata-manager-0]
2021-11-18 13:28:48,604 INFO [Log partition=__consumer_offsets-32, dir=/var/lib/kafka/data/kafka-log0] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log) [ReplicaFetcherThread-0-2]
2021-11-18 13:28:48,604 TRACE [Controller id=0 epoch=2] Received response LeaderAndIsrResponseData(errorCode=0, partitionErrors=[], topics=[LeaderAndIsrTopicError(topicId=WQfOhFctS1uL8n4wUAgQbw, partitionErrors=[LeaderAndIsrPartitionError(topicName='', partitionIndex=2, errorCode=0)]), LeaderAndIsrTopicError(topicId=yYd9hdvQQqSPLkTgoXWQTg, partitionErrors=[LeaderAndIsrPartitionError(topicName='', partitionIndex=2, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=35, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=38, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=5, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=8, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=26, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=29, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=32, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=17, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=20, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=23, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=41, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=44, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=11, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=14, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=47, errorCode=0)]), LeaderAndIsrTopicError(topicId=0qhjgX--QlCRfVMPdOj9Ew, partitionErrors=[LeaderAndIsrPartitionError(topicName='', partitionIndex=2, errorCode=0)]), LeaderAndIsrTopicError(topicId=OdkjQMwvR0mNNX853I4w6g, partitionErrors=[LeaderAndIsrPartitionError(topicName='', partitionIndex=0, errorCode=0)])]) for request LEADER_AND_ISR with correlation id 21 sent to broker my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091 (id: 0 rack: null) (state.change.logger) [Controller-0-to-broker-0-send-thread]
2021-11-18 13:28:48,604 INFO [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-14 to local high watermark 0 (kafka.server.ReplicaFetcherThread) [ReplicaFetcherThread-0-2]
2021-11-18 13:28:48,604 INFO [Log partition=__consumer_offsets-14, dir=/var/lib/kafka/data/kafka-log0] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log) [ReplicaFetcherThread-0-2]
2021-11-18 13:28:48,604 INFO [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-26 to local high watermark 0 (kafka.server.ReplicaFetcherThread) [ReplicaFetcherThread-0-2]
2021-11-18 13:28:48,604 INFO [Log partition=__consumer_offsets-26, dir=/var/lib/kafka/data/kafka-log0] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log) [ReplicaFetcherThread-0-2]
2021-11-18 13:28:48,604 INFO [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-8 to local high watermark 0 (kafka.server.ReplicaFetcherThread) [ReplicaFetcherThread-0-2]
2021-11-18 13:28:48,604 INFO [Log partition=__consumer_offsets-8, dir=/var/lib/kafka/data/kafka-log0] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log) [ReplicaFetcherThread-0-2]
2021-11-18 13:28:48,604 INFO [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-38 to local high watermark 0 (kafka.server.ReplicaFetcherThread) [ReplicaFetcherThread-0-2]
2021-11-18 13:28:48,604 INFO [Log partition=__consumer_offsets-38, dir=/var/lib/kafka/data/kafka-log0] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log) [ReplicaFetcherThread-0-2]
2021-11-18 13:28:48,604 INFO [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-20 to local high watermark 0 (kafka.server.ReplicaFetcherThread) [ReplicaFetcherThread-0-2]
2021-11-18 13:28:48,604 INFO [Log partition=__consumer_offsets-20, dir=/var/lib/kafka/data/kafka-log0] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log) [ReplicaFetcherThread-0-2]
2021-11-18 13:28:48,604 INFO [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-2 to local high watermark 0 (kafka.server.ReplicaFetcherThread) [ReplicaFetcherThread-0-2]
2021-11-18 13:28:48,604 INFO [Log partition=__consumer_offsets-2, dir=/var/lib/kafka/data/kafka-log0] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log) [ReplicaFetcherThread-0-2]
2021-11-18 13:28:48,604 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='test-topic-3', partitionIndex=2, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], offlineReplicas=[]) for partition test-topic-3-2 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='test-topic-1', partitionIndex=2, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], offlineReplicas=[]) for partition test-topic-1-2 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=47, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], offlineReplicas=[]) for partition __consumer_offsets-47 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=14, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], offlineReplicas=[]) for partition __consumer_offsets-14 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=11, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], offlineReplicas=[]) for partition __consumer_offsets-11 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=44, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], offlineReplicas=[]) for partition __consumer_offsets-44 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=41, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], offlineReplicas=[]) for partition __consumer_offsets-41 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=23, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], offlineReplicas=[]) for partition __consumer_offsets-23 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=20, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], offlineReplicas=[]) for partition __consumer_offsets-20 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=17, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], offlineReplicas=[]) for partition __consumer_offsets-17 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=32, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], offlineReplicas=[]) for partition __consumer_offsets-32 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=29, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], offlineReplicas=[]) for partition __consumer_offsets-29 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=26, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], offlineReplicas=[]) for partition __consumer_offsets-26 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=8, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], offlineReplicas=[]) for partition __consumer_offsets-8 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=5, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], offlineReplicas=[]) for partition __consumer_offsets-5 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=38, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], offlineReplicas=[]) for partition __consumer_offsets-38 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=35, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 0, 1], offlineReplicas=[]) for partition __consumer_offsets-35 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=2, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], offlineReplicas=[]) for partition __consumer_offsets-2 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='test-topic-2', partitionIndex=0, controllerEpoch=2, leader=2, leaderEpoch=4, isr=[0, 1, 2], zkVersion=7, replicas=[2, 1, 0], offlineReplicas=[]) for partition test-topic-2-0 in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 INFO [Broker id=0] Add 19 partitions and deleted 0 partitions from metadata cache in response to UpdateMetadata request sent by controller 0 epoch 2 with correlation id 22 (state.change.logger) [data-plane-kafka-request-handler-4]
2021-11-18 13:28:48,695 TRACE [Controller id=0 epoch=2] Received response UpdateMetadataResponseData(errorCode=0) for request UPDATE_METADATA with correlation id 22 sent to broker my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091 (id: 0 rack: null) (state.change.logger) [Controller-0-to-broker-0-send-thread]
2021-11-18 13:28:49,400 TRACE [Controller id=0 epoch=2] Received response LeaderAndIsrResponseData(errorCode=0, partitionErrors=[], topics=[LeaderAndIsrTopicError(topicId=WQfOhFctS1uL8n4wUAgQbw, partitionErrors=[LeaderAndIsrPartitionError(topicName='', partitionIndex=2, errorCode=0)]), LeaderAndIsrTopicError(topicId=yYd9hdvQQqSPLkTgoXWQTg, partitionErrors=[LeaderAndIsrPartitionError(topicName='', partitionIndex=2, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=35, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=38, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=5, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=8, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=26, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=29, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=32, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=17, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=20, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=23, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=41, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=44, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=11, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=14, errorCode=0), LeaderAndIsrPartitionError(topicName='', partitionIndex=47, errorCode=0)]), LeaderAndIsrTopicError(topicId=0qhjgX--QlCRfVMPdOj9Ew, partitionErrors=[LeaderAndIsrPartitionError(topicName='', partitionIndex=2, errorCode=0)]), LeaderAndIsrTopicError(topicId=OdkjQMwvR0mNNX853I4w6g, partitionErrors=[LeaderAndIsrPartitionError(topicName='', partitionIndex=0, errorCode=0)])]) for request LEADER_AND_ISR with correlation id 21 sent to broker my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091 (id: 1 rack: null) (state.change.logger) [Controller-0-to-broker-1-send-thread]
2021-11-18 13:28:49,496 TRACE [Controller id=0 epoch=2] Received response UpdateMetadataResponseData(errorCode=0) for request UPDATE_METADATA with correlation id 22 sent to broker my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-nagraju-c3.svc:9091 (id: 1 rack: null) (state.change.logger) [Controller-0-to-broker-1-send-thread]
2021-11-18 13:28:49,996 WARN [Log partition=test-topic-2-0, dir=/var/lib/kafka/data/kafka-log0] Non-monotonic update of high watermark from (offset=8720474 segment=[0:78642859]) to (offset=8718716 segment=[-1:-1]) (kafka.log.Log) [ReplicaFetcherThread-0-2]
2021-11-18 13:33:47,997 INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:33:47,997 TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:33:47,998 DEBUG [Controller id=0] Topics not in preferred replica for broker 0 HashMap() (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:33:47,998 TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:33:47,998 DEBUG [Controller id=0] Topics not in preferred replica for broker 1 HashMap(test-topic-2-1 -> List(1, 0, 2), test-topic-3-0 -> List(1, 2, 0)) (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:33:47,998 TRACE [Controller id=0] Leader imbalance ratio for broker 1 is 0.09523809523809523 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:33:47,998 DEBUG [Controller id=0] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:33:47,998 TRACE [Controller id=0] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:38:47,999 INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:38:47,999 TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:38:47,999 DEBUG [Controller id=0] Topics not in preferred replica for broker 0 HashMap() (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:38:47,999 TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:38:47,999 DEBUG [Controller id=0] Topics not in preferred replica for broker 1 HashMap(test-topic-2-1 -> List(1, 0, 2), test-topic-3-0 -> List(1, 2, 0)) (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:38:47,999 TRACE [Controller id=0] Leader imbalance ratio for broker 1 is 0.09523809523809523 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:38:48,000 DEBUG [Controller id=0] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:38:48,000 TRACE [Controller id=0] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:43:48,000 INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:43:48,000 TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:43:48,001 DEBUG [Controller id=0] Topics not in preferred replica for broker 0 HashMap() (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:43:48,001 TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:43:48,001 DEBUG [Controller id=0] Topics not in preferred replica for broker 1 HashMap(test-topic-2-1 -> List(1, 0, 2), test-topic-3-0 -> List(1, 2, 0)) (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:43:48,001 TRACE [Controller id=0] Leader imbalance ratio for broker 1 is 0.09523809523809523 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:43:48,001 DEBUG [Controller id=0] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:43:48,001 TRACE [Controller id=0] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:48:48,001 INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:48:48,001 TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:48:48,002 DEBUG [Controller id=0] Topics not in preferred replica for broker 0 HashMap() (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:48:48,002 TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:48:48,002 DEBUG [Controller id=0] Topics not in preferred replica for broker 1 HashMap(test-topic-2-1 -> List(1, 0, 2), test-topic-3-0 -> List(1, 2, 0)) (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:48:48,002 TRACE [Controller id=0] Leader imbalance ratio for broker 1 is 0.09523809523809523 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:48:48,002 DEBUG [Controller id=0] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:48:48,002 TRACE [Controller id=0] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:53:48,310 INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:53:48,310 TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:53:48,311 DEBUG [Controller id=0] Topics not in preferred replica for broker 0 HashMap() (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:53:48,311 TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:53:48,311 DEBUG [Controller id=0] Topics not in preferred replica for broker 1 HashMap(test-topic-2-1 -> List(1, 0, 2), test-topic-3-0 -> List(1, 2, 0)) (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:53:48,311 TRACE [Controller id=0] Leader imbalance ratio for broker 1 is 0.09523809523809523 (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:53:48,311 DEBUG [Controller id=0] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController) [controller-event-thread]
2021-11-18 13:53:48,311 TRACE [Controller id=0] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController) [controller-event-thread]
Topic created using follwoing command:
bin/kafka-topics.sh --bootstrap-server 182.65.15.152:30058 --create --topic test-topic-3 --partitions 3 --replication-factor 3 --command-config /rolling-up/kafka.client.txt
Beta Was this translation helpful? Give feedback.
All reactions