You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "yonglu gao (Jira)" <ji...@apache.org> on 2020/04/15 04:03:00 UTC
[jira] [Updated] (KAFKA-9870) Error is reported until the cluster
is restarted. Error for partition [__consumer_offsets,19] to broker
0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This
server is not the leader for that topic-partition.
[ https://issues.apache.org/jira/browse/KAFKA-9870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
yonglu gao updated KAFKA-9870:
------------------------------
Description:
I have a kafka cluster .when broker 2 restart,then error,Error is reported until the cluster is restarted in turn after 3 hours:
broker2:
ERROR [KafkaApi-2] Error when handling request \{replica_id=0,max_wait_time=500,min_bytes=1,max_bytes=10485760,isolation_level=0,topics=[{topic=__consumer_offsets,partitions=[{partition=13,fetch_offset=17465556,log_start_offset=0,max_bytes=1048576}]}]} (kafka.server.KafkaApis)RROR [KafkaApi-2] Error when handling request \{replica_id=0,max_wait_time=500,min_bytes=1,max_bytes=10485760,isolation_level=0,topics=[{topic=__consumer_offsets,partitions=[{partition=13,fetch_offset=17465556,log_start_offset=0,max_bytes=1048576}]}]} (kafka.server.KafkaApis)kafka.common.NotAssignedReplicaException: Leader 2 failed to record follower 0's position -1 since the replica is not recognized to be one of the assigned replicas for partition __consumer_offsets-13. at kafka.cluster.Partition.updateReplicaLogReadResult(Partition.scala:274)
[2020-04-11 03:01:45,760] INFO Partition [__consumer_offsets,13] on broker 2: Shrinking ISR from 2,1,0 to 2 (kafka.cluster.Partition)
[2020-04-11 03:02:32,046] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,19] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
[2020-04-11 03:02:32,053] ERROR [ReplicaFetcherThread-0-0]: Error for partition [base_registerAndCardAdd,26] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
[2020-04-11 03:02:32,059] ERROR [ReplicaFetcherThread-0-0]: Error for partition [mac-base-topic,15] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
[2020-04-11 03:02:32,067] ERROR [ReplicaFetcherThread-0-0]: Error for partition [pay-total-order-topic,24] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
[2020-04-11 03:02:32,072] ERROR [ReplicaFetcherThread-0-0]: Error for partition [pay-total-order-topic,30] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
[2020-04-11 03:02:32,078] ERROR [ReplicaFetcherThread-0-0]: Error for partition [base_registerAndCardAdd,56] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
[2020-04-11 03:02:32,087] ERROR [ReplicaFetcherThread-0-0]: Error for partition [mac-dbasync-topic,45] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
*All of these are errors until you restart the cluster*
* broker0&1:*
2020-04-11 03:02:05,261] WARN [ReplicaFetcherThread-0-2]: Error in fetch to broker 2, request (type=FetchRequest, replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={__consumer_offsets-13=(offset=17477531, logStartOffset=0, maxBytes=1048576)}) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:93)
at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:93)
at kafka.server.ReplicaFetcherThread.fetch(ReplicaFetcherThread.scala:207)
at kafka.server.ReplicaFetcherThread.fetch(ReplicaFetcherThread.scala:42)
at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:151)
at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:112)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
[2020-04-11 03:02:32,041] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions __consumer_offsets-19 (kafka.server.ReplicaFetcherManager)
[2020-04-11 03:02:32,041] INFO [ReplicaFetcherManager on broker 1] Added fetcher for partitions List([__consumer_offsets-19, initOffset 0 to broker BrokerEndPoint(2,19.13.139.125,9092)] ) (kafka.server.ReplicaFetcherManager)
[2020-04-11 03:02:32,041] INFO [Group Metadata Manager on Broker 1]: Scheduling unloading of offsets and group metadata from __consumer_offsets-19 (kafka.coordinator.group.GroupMetadataManager)
[2020-04-11 03:02:32,041] INFO [Group Metadata Manager on Broker 1]: Finished unloading __consumer_offsets-19. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2020-04-11 03:02:32,047] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions base_registerAndCardAdd-26 (kafka.server.ReplicaFetcherManager)
[2020-04-11 03:02:32,047] INFO [ReplicaFetcherManager on broker 1] Added fetcher for partitions List([base_registerAndCardAdd-26, initOffset 18734 to broker BrokerEndPoint(2,19.13.139.125,9092)] ) (kafka.server.ReplicaFetcherManager)
[202
zk is ok。
was:
I have a kafka cluster .when broker 2 restart,then error,Error is reported until the cluster is restarted in turn after 3 hours:
broker2:
ERROR [KafkaApi-2] Error when handling request \{replica_id=0,max_wait_time=500,min_bytes=1,max_bytes=10485760,isolation_level=0,topics=[{topic=__consumer_offsets,partitions=[{partition=13,fetch_offset=17465556,log_start_offset=0,max_bytes=1048576}]}]} (kafka.server.KafkaApis)kafka.common.NotAssignedReplicaException: Leader 2 failed to record follower 0's position -1 since the replica is not recognized to be one of the assigned replicas for partition __consumer_offsets-13. at kafka.cluster.Partition.updateReplicaLogReadResult(Partition.scala:274) at kafka.server.ReplicaManager$$anonfun$updateFollowerLogReadResults$2.apply(ReplicaManager.scala:1091) at kafka.server.ReplicaManager$$anonfun$updateFollowerLogReadResults$2.apply(ReplicaManager.scala:1088) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48) at kafka.server.ReplicaManager.updateFollowerLogReadResults(ReplicaManager.scala:1088) at kafka.server.ReplicaManager.fetchMessages(ReplicaManager.scala:622) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:606) at kafka.server.KafkaApis.handle(KafkaApis.scala:98) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:66) at java.lang.Thread.run(Thread.java:748) [2020-04-11 03:00:32,285] INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions test-2,base_registerAndCardAdd-25,pay-total-order-topic-30,base_registerAndCardAdd-7,pay-total-order-topic-12,base_registerAndCardAdd-51,mac-dbasync-topic-51,test-10,base_registerAndCardAdd-33,pay-total-order-topic-38,mac-base-topic-26,base_registerAndCardAdd-15,pay-total-order-topic-39,mac-dbasync-topic-59,mac-base-topic-8,pay-total-order-topic-21,test-0,base_registerAndCardAdd-23,pay-total-order-topic-3,pay-total-order-topic-47,mac-base-topic-16,base_registerAndCardAdd-24,pay-total-order-topic-29,__consumer_offsets-31,mac-dbasync-topic-31,mac-base-topic-24,mac-dbasync-topic-13,mac-dbasync-topic-57,mac-base-topic-6,__consumer_offsets-39,mac-dbasync-topic-39,mac-dbasync-topic-21,mac-base-topic-14,mac-dbasync-topic-47,__consumer_offsets-48,pay-total-order-topic-9,mac-dbasync-topic-48,__consumer_offsets-30,mac-dbasync-topic-30,mac-base-topic-4,__consumer_offsets-19,mac-dbasync-topic-19,base-beginnerOper-topic-56,__consumer_offsets-1,mac-dbasync-topic-1,base-beginnerOper-topic-38,__consumer_offsets-2,base-beginnerOper-topic-20,__consumer_offsets-28,base-beginnerOper-topic-46,__consumer_offsets-10,base-beginnerOper-topic-28,__consumer_offsets-36,base-beginnerOper-topic-54,__consumer_offsets-18,base_registerAndCardAdd-56,pay-total-order-topic-61,base-beginnerOper-topic-36,base_registerAndCardAdd-38,base-beginnerOper-topic-18,base-beginnerOper-topic-0,base-beginnerOper-topic-44,base_registerAndCardAdd-46,base-beginnerOper-topic-26,base-beginnerOper-topic-8,base-beginnerOper-topic-16,pay-total-order-topic-60,pay-total-order-topic-23,mac-dbasync-topic-62,base_registerAndCardAdd-0,base_registerAndCardAdd-44,mac-dbasync-topic-44,test-3,base_registerAndCardAdd-26,pay-total-order-topic-31,mac-base-topic-19,base_registerAndCardAdd-8,pay-total-order-topic-32,mac-base-topic-1,test-11,pay-total-order-topic-14,pay-total-order-topic-58,mac-base-topic-27,test-12,base_registerAndCardAdd-16,pay-total-order-topic-40,base_registerAndCardAdd-17,pay-total-order-topic-22,base_registerAndCardAdd-43,pay-total-order-topic-48,pay-total-order-topic-4,mac-dbasync-topic-24,mac-base-topic-17,mac-dbasync-topic-50,mac-dbasync-topic-6,mac-dbasync-topic-32,mac-base-topic-25,mac-dbasync-topic-58,mac-base-topic-7,pay-total-order-topic-20,mac-dbasync-topic-40,__consumer_offsets-41,pay-total-order-topic-2,mac-dbasync-topic-41,__consumer_offsets-23,mac-dbasync-topic-23,__consumer_offsets-49,base_registerAndCardAdd-5,mac-dbasync-topic-49,__consumer_offsets-12,mac-dbasync-topic-12,base-beginnerOper-topic-49,base-beginnerOper-topic-31,base-beginnerOper-topic-57,base-beginnerOper-topic-13,__consumer_offsets-21,base-beginnerOper-topic-39,__consumer_offsets-3,__consumer_offsets-47,mac-dbasync-topic-3,__consumer_offsets-29,mac-dbasync-topic-29,base-beginnerOper-topic-47,__consumer_offsets-11,mac-dbasync-topic-11,base-beginnerOper-topic-48,base_registerAndCardAdd-31,base-beginnerOper-topic-11,base_registerAndCardAdd-57,base-beginnerOper-topic-37,pay-total-order-topic-63,base-beginnerOper-topic-19,base-beginnerOper-topic-1,base-beginnerOper-topic-9,pay-total-order-topic-53,pay-total-order-topic-35,base-beginnerOper-topic-10,base_registerAndCardAdd-37,mac-base-topic-30,base_registerAndCardAdd-19,pay-total-order-topic-43,mac-base-topic-12,base_registerAndCardAdd-1,base_registerAndCardAdd-20,pay-total-order-topic-25,test-4,pay-total-order-topic-7,pay-total-order-topic-51,test-5,base_registerAndCardAdd-28,pay-total-order-topic-33,base_registerAndCardAdd-10,pay-total-order-topic-15,pay-total-order-topic-59,base_registerAndCardAdd-54,test-13,base_registerAndCardAdd-36,pay-total-order-topic-41,base_registerAndCardAdd-18,base_registerAndCardAdd-62,mac-dbasync-topic-43,__consumer_offsets-44,pay-total-order-topic-5,mac-dbasync-topic-25,mac-base-topic-18,base-beginnerOper-topic-62,mac-base-topic-0,pay-total-order-topic-13,mac-dbasync-topic-52,__consumer_offsets-34,mac-dbasync-topic-34,__consumer_offsets-16,mac-dbasync-topic-60,mac-dbasync-topic-16,mac-base-topic-9,__consumer_offsets-42,mac-dbasync-topic-42,test-1,__consumer_offsets-24,base-beginnerOper-topic-42,__consumer_offsets-6,base-beginnerOper-topic-24,__consumer_offsets-32,base-beginnerOper-topic-50,__consumer_offsets-14,mac-dbasync-topic-14,base-beginnerOper-topic-32,__consumer_offsets-40,base-beginnerOper-topic-58,__consumer_offsets-22,mac-dbasync-topic-22,base-beginnerOper-topic-59,__consumer_offsets-4,mac-dbasync-topic-4,base-beginnerOper-topic-41,base_registerAndCardAdd-50,base-beginnerOper-topic-30,pay-total-order-topic-56,base-beginnerOper-topic-12,base_registerAndCardAdd-59,base_registerAndCardAdd-41,pay-total-order-topic-46,base-beginnerOper-topic-21,base-beginnerOper-topic-3,base_registerAndCardAdd-49,base-beginnerOper-topic-29,base_registerAndCardAdd-12,pay-total-order-topic-36,test-15,base_registerAndCardAdd-13,pay-total-order-topic-62,pay-total-order-topic-18,mac-base-topic-31,base_registerAndCardAdd-39,pay-total-order-topic-0,pay-total-order-topic-44,base_registerAndCardAdd-21,pay-total-order-topic-26,base_registerAndCardAdd-3,pay-total-order-topic-8,base_registerAndCardAdd-47,pay-total-order-topic-52,test-6,base_registerAndCardAdd-29,pay-total-order-topic-34,mac-base-topic-22,base_registerAndCardAdd-55,pay-total-order-topic-16,base_registerAndCardAdd-11,mac-dbasync-topic-55,test-14,__consumer_offsets-37,mac-dbasync-topic-37,mac-base-topic-11,pay-total-order-topic-24,mac-dbasync-topic-63,__consumer_offsets-45,pay-total-order-topic-6,mac-dbasync-topic-45,__consumer_offsets-27,mac-dbasync-topic-27,mac-base-topic-20,base_registerAndCardAdd-9,__consumer_offsets-9,mac-dbasync-topic-9,mac-dbasync-topic-53,mac-base-topic-2,__consumer_offsets-35,mac-dbasync-topic-35,mac-base-topic-28,mac-dbasync-topic-61,mac-dbasync-topic-17,mac-base-topic-10,base-beginnerOper-topic-17,base-beginnerOper-topic-61,__consumer_offsets-25,base-beginnerOper-topic-43,__consumer_offsets-7,mac-dbasync-topic-7,__consumer_offsets-33,mac-dbasync-topic-33,__consumer_offsets-15,mac-dbasync-topic-15,base-beginnerOper-topic-52,base-beginnerOper-topic-34,base-beginnerOper-topic-60,__consumer_offsets-5,mac-dbasync-topic-5,base-beginnerOper-topic-23,base-beginnerOper-topic-5,pay-total-order-topic-49,base-beginnerOper-topic-6,base_registerAndCardAdd-52,pay-total-order-topic-57,base_registerAndCardAdd-34,base-beginnerOper-topic-14,base_registerAndCardAdd-60,base-beginnerOper-topic-40,base_registerAndCardAdd-42,base-beginnerOper-topic-22,base-beginnerOper-topic-4,test-8,base_registerAndCardAdd-6,pay-total-order-topic-55,pay-total-order-topic-11,test-9,base_registerAndCardAdd-32,pay-total-order-topic-37,base_registerAndCardAdd-14,base_registerAndCardAdd-58,pay-total-order-topic-19,base_registerAndCardAdd-40,pay-total-order-topic-45,pay-total-order-topic-1,base_registerAndCardAdd-22,pay-total-order-topic-27,base-beginnerOper-topic-2,mac-base-topic-15,base_registerAndCardAdd-48,base_registerAndCardAdd-4,pay-total-order-topic-28,test-7,base_registerAndCardAdd-30,pay-total-order-topic-10,pay-total-order-topic-54,mac-base-topic-23,pay-total-order-topic-17,mac-dbasync-topic-56,mac-base-topic-5,__consumer_offsets-38,mac-dbasync-topic-38,__consumer_offsets-20,mac-dbasync-topic-20,mac-base-topic-13,base_registerAndCardAdd-2,__consumer_offsets-46,mac-dbasync-topic-46,mac-dbasync-topic-2,mac-dbasync-topic-28,mac-base-topic-21,mac-dbasync-topic-10,mac-dbasync-topic-54,mac-base-topic-3,mac-dbasync-topic-36,mac-base-topic-29,mac-dbasync-topic-18,base-beginnerOper-topic-55,__consumer_offsets-0,mac-dbasync-topic-0,__consumer_offsets-26,mac-dbasync-topic-26,base-beginnerOper-topic-63,__consumer_offsets-8,mac-dbasync-topic-8,base-beginnerOper-topic-45,base-beginnerOper-topic-27,base-beginnerOper-topic-53,__consumer_offsets-17,base-beginnerOper-topic-35,__consumer_offsets-43,pay-total-order-topic-42,base_registerAndCardAdd-63,base_registerAndCardAdd-45,pay-total-order-topic-50,base-beginnerOper-topic-25,base_registerAndCardAdd-27,base-beginnerOper-topic-7,base-beginnerOper-topic-51,base_registerAndCardAdd-53,base-beginnerOper-topic-33,base_registerAndCardAdd-35,base-beginnerOper-topic-15,base_registerAndCardAdd-61 (kafka.server.ReplicaFetcherManager)[2020-04-11 03:00:32,340] INFO [ReplicaFetcherThread-0-1]: Starting (kafka.server.ReplicaFetcherThread)[2020-04-11 03:00:32,347] INFO [ReplicaFetcherThread-0-0]: Starting (kafka.server.ReplicaFetcherThread)[2020-04-11 03:00:32,352] INFO [ReplicaFetcherManager on broker 2] Added fetcher for partitions List([mac-base-topic-19, initOffset 80590 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-22, initOffset 190216 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-58, initOffset 18685 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-22, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-14, initOffset 80357 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-32, initOffset 190219 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-24, initOffset 25493 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-41, initOffset 87480 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-43, initOffset 190220 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-7, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-8, initOffset 20777 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-20, initOffset 38140 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [test-14, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-34, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-52, initOffset 190220 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-base-topic-16, initOffset 84743 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-30, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-58, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-38, initOffset 190219 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-42, initOffset 27666 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-base-topic-8, initOffset 41784 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-3, initOffset 8588 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-19, initOffset 115677 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-27, initOffset 61210 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-0, initOffset 13650 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [test-6, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-8, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-55, initOffset 91332 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-11, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-31, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-16, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-21, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-47, initOffset 121845 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-13, initOffset 190216 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-4, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-27, initOffset 31300 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-57, initOffset 188919 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-58, initOffset 190216 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-base-topic-3, initOffset 17170 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-59, initOffset 190219 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-25, initOffset 76126 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-29, initOffset 190218 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-17, initOffset 121809 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-24, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-22, initOffset 65604 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-31, initOffset 44717 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-42, initOffset 188920 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-0, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-27, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-61, initOffset 50482 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-7, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-33, initOffset 6937 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-56, initOffset 190221 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-9, initOffset 2968977 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-49, initOffset 190216 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-47, initOffset 190218 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-46, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-37, initOffset 12124 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-4, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-40, initOffset 190216 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-8, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-1, initOffset 190220 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-44, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-44, initOffset 108057 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-30, initOffset 9009 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-45, initOffset 37853 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-15, initOffset 41106 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-54, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-19, initOffset 40269 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [test-11, initOffset 1 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [test-10, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-6, initOffset 64490 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-14, initOffset 117599 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-25, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-62, initOffset 190221 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-35, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-49, initOffset 42922 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-4, initOffset 190216 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-38, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-46, initOffset 40092 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-63, initOffset 188923 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-51, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-41, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-9, initOffset 24731 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-36, initOffset 52248 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-58, initOffset 68091 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-50, initOffset 119192 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-46, initOffset 190216 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-33, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-47, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-23, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-50, initOffset 41357 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-49, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-12, initOffset 107711 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-0, initOffset 41744 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-45, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-37, initOffset 190219 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-16, initOffset 42549 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-0, initOffset 6875 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-12, initOffset 188919 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-2, initOffset 190218 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-21, initOffset 188922 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-51, initOffset 188918 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-34, initOffset 44867 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-47, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-16, initOffset 5833535 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [test-0, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-base-topic-18, initOffset 83079 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-28, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [test-7, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-7, initOffset 71909 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-32, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-8, initOffset 80082 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-2, initOffset 14627 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-31, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-36, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-36, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-23, initOffset 58310 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-26, initOffset 37443 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-12, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-37, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-42, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-25, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-29, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-16, initOffset 120985 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-50, initOffset 190219 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-3, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-24, initOffset 83055 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-25, initOffset 22194 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-29, initOffset 10594 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-54, initOffset 98999 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-46, initOffset 119960 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-17, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-18, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-41, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-28, initOffset 190220 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-base-topic-1, initOffset 13804 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-62, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-16, initOffset 190217 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-9, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-17, initOffset 85505 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-5, initOffset 24260 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-37, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-23, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-40, initOffset 79373 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-44, initOffset 35030 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-52, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-35, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-63, initOffset 7858 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-base-topic-9, initOffset 49328 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [test-5, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-43, initOffset 31147 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-30, initOffset 45438 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-1, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-60, initOffset 54775 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-base-topic-12, initOffset 69708 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-9, initOffset 188923 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-34, initOffset 7286 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-59, initOffset 60790 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-15, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-24, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-55, initOffset 190216 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-39, initOffset 17487 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-13, initOffset 113701 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-53, initOffset 35721 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-7, initOffset 190219 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-3, initOffset 188920 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-22, initOffset 32776 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-59, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-25, initOffset 190221 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-37, initOffset 58291 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-49, initOffset 120935 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-base-topic-29, initOffset 21386 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-55, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-20, initOffset 190218 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-45, initOffset 188923 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-57, initOffset 75645 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-1, initOffset 6867 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-24, initOffset 50715 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-35, initOffset 48576 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-60, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-5, initOffset 12120 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-6, initOffset 188919 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-26, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-36, initOffset 188923 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-11, initOffset 101772 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-21, initOffset 70980 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-54, initOffset 188923 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-38, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-11, initOffset 190220 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-17, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-48, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-15, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-2, initOffset 44036 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-19, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-63, initOffset 43169 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-33, initOffset 42801 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [test-8, initOffset 1 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-42, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-48, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-27, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-30, initOffset 17961 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [test-1, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-39, initOffset 71302 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-6, initOffset 29499 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-53, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-39, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-27, initOffset 188923 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-19, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-62, initOffset 8967 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-45, initOffset 114237 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-36, initOffset 9823 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-26, initOffset 190221 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-55, initOffset 29123 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-11, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-9, initOffset 87689 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-11, initOffset 62285 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-53, initOffset 106089 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-17, initOffset 42479 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-22, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-18, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-14, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-15, initOffset 119642 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-23, initOffset 90311 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-21, initOffset 35328 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-8, initOffset 190222 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-51, initOffset 40321 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-1, initOffset 42525 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-10, initOffset 190219 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-15, initOffset 188920 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-52, initOffset 38822 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-22, initOffset 98857 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-2, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-43, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-52, initOffset 110803 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-6, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-10, initOffset 27907 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-6, initOffset 15009 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-56, initOffset 25271 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-10, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-14, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-2, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [test-13, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [test-4, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-61, initOffset 10780 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-35, initOffset 8587 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-26, initOffset 18728 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-31, initOffset 7650 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-17, initOffset 190222 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-3, initOffset 48430 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-31, initOffset 190216 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-40, initOffset 20986 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-61, initOffset 190220 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-49, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-33, initOffset 188918 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-14, initOffset 40170 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-6, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-24, initOffset 188921 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-30, initOffset 188919 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-4, initOffset 10315 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-2, initOffset 7339 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-35, initOffset 190222 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-44, initOffset 190223 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-20, initOffset 110073 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-28, initOffset 55776 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-base-topic-28, initOffset 25805 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-3, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-50, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-53, initOffset 190223 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-7, initOffset 18143 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-20, initOffset 77069 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-14, initOffset 190217 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-25, initOffset 44295 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-30, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-5, initOffset 57619 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-19, initOffset 190219 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-28, initOffset 12934 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-4, initOffset 20138 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-56, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-20, initOffset 243 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-0, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-44, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-48, initOffset 122171 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-12, initOffset 34758 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-56, initOffset 83977 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [test-9, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-26, initOffset 67971 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-18, initOffset 117038 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-40, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-base-topic-10, initOffset 55573 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-28, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-39, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-61, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-32, initOffset 42976 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-7, initOffset 35630 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-63, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-base-topic-31, initOffset 15508 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-20, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-12, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-42, initOffset 94468 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-base-topic-15, initOffset 82517 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-39, initOffset 188921 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-32, initOffset 6777 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-41, initOffset 24642 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-43, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-47, initOffset 41520 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-48, initOffset 188920 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-34, initOffset 190220 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-45, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-41, initOffset 190220 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-4, initOffset 52767 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-1, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-5, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-13, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-26, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-62, initOffset 45946 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-13, initOffset 37206 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-60, initOffset 12871 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-18, initOffset 188923 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-29, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-59, initOffset 15419 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-10, initOffset 94523 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-5, initOffset 190218 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-23, initOffset 190217 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-34, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-23, initOffset 29139 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-10, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-18, initOffset 41833 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-38, initOffset 14541 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-27, initOffset 15916 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-43, initOffset 101158 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base-beginnerOper-topic-5, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [test-3, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-base-topic-13, initOffset 75059 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [__consumer_offsets-32, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [test-12, initOffset 1 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [test-15, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-51, initOffset 115492 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [__consumer_offsets-40, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [test-2, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-11, initOffset 31073 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-46, initOffset 0 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-48, initOffset 42194 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [pay-total-order-topic-38, initOffset 64756 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-21, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-29, initOffset 50006 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [mac-dbasync-topic-0, initOffset 188920 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-33, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [pay-total-order-topic-21, initOffset 106094 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base-beginnerOper-topic-57, initOffset 0 to broker BrokerEndPoint(1,19.13.139.124,9092)] , [base_registerAndCardAdd-57, initOffset 22101 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [base_registerAndCardAdd-54, initOffset 32828 to broker BrokerEndPoint(0,19.13.139.123,9092)] , [mac-dbasync-topic-60, initOffset 188923 to broker BrokerEndPoint(1,19.13.139.124,9092)] ) (kafka.server.ReplicaFetcherManager)[2020-04-11 03:00:32,365] INFO [ReplicaFetcherThread-0-0]: Based on follower's leader epoch, leader replied with an offset 190295 >= the follower's log end offset 190216 in mac-dbasync-topic-55. No truncation needed. (kafka.server.ReplicaFetcherThread)[2020-04-11 03:00:33,729] INFO Updated PartitionLeaderEpoch. New: \{epoch:1, offset:119642}, Current: \{epoch:0, offset0} for Partition: pay-total-order-topic-15. Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)[2020-04-11 03:00:33,736] INFO Updated PartitionLeaderEpoch. New: \{epoch:1, offset:48430}, Current: \{epoch:0, offset0} for Partition: pay-total-order-topic-3. Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)[2020-04-11 03:00:33,740] INFO Updated PartitionLeaderEpoch. New: \{epoch:1, offset:115492}, Current: \{epoch:0, offset0} for Partition: pay-total-order-topic-51. Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)[2020-04-11 03:00:33,744] INFO Updated PartitionLeaderEpoch. New: \{epoch:1, offset:106094}, Current: \{epoch:0, offset0} for Partition: pay-total-order-topic-21. Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2020-04-11 03:01:45,760] INFO Partition [__consumer_offsets,13] on broker 2: Shrinking ISR from 2,1,0 to 2 (kafka.cluster.Partition)[2020-04-11 03:02:32,046] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,19] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)[2020-04-11 03:02:32,053] ERROR [ReplicaFetcherThread-0-0]: Error for partition [base_registerAndCardAdd,26] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)[2020-04-11 03:02:32,059] ERROR [ReplicaFetcherThread-0-0]: Error for partition [mac-base-topic,15] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)[2020-04-11 03:02:32,067] ERROR [ReplicaFetcherThread-0-0]: Error for partition [pay-total-order-topic,24] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)[2020-04-11 03:02:32,072] ERROR [ReplicaFetcherThread-0-0]: Error for partition [pay-total-order-topic,30] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)[2020-04-11 03:02:32,078] ERROR [ReplicaFetcherThread-0-0]: Error for partition [base_registerAndCardAdd,56] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)[2020-04-11 03:02:32,087] ERROR [ReplicaFetcherThread-0-0]: Error for partition [mac-dbasync-topic,45] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)[2020-04-11 03:02:32,098] ERROR [ReplicaFetcherThread-0-0]: Error for partition [test,11] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)[2020-04-11 03:02:32,106] ERROR [ReplicaFetcherThread-0-0]: Error for partition [pay-total-order-topic,12] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
broker0&1:
2020-04-11 03:02:05,261] WARN [ReplicaFetcherThread-0-2]: Error in fetch to broker 2, request (type=FetchRequest, replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760, fetchData=\{__consumer_offsets-13=(offset=17477531, logStartOffset=0, maxBytes=1048576)}) (kafka.server.ReplicaFetcherThread)java.io.IOException: Connection to 2 was disconnected before the response was read at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:93) at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:93) at kafka.server.ReplicaFetcherThread.fetch(ReplicaFetcherThread.scala:207) at kafka.server.ReplicaFetcherThread.fetch(ReplicaFetcherThread.scala:42) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:151) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:112) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)[2020-04-11 03:02:32,041] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions __consumer_offsets-19 (kafka.server.ReplicaFetcherManager)[2020-04-11 03:02:32,041] INFO [ReplicaFetcherManager on broker 1] Added fetcher for partitions List([__consumer_offsets-19, initOffset 0 to broker BrokerEndPoint(2,19.13.139.125,9092)] ) (kafka.server.ReplicaFetcherManager)[2020-04-11 03:02:32,041] INFO [Group Metadata Manager on Broker 1]: Scheduling unloading of offsets and group metadata from __consumer_offsets-19 (kafka.coordinator.group.GroupMetadataManager)[2020-04-11 03:02:32,041] INFO [Group Metadata Manager on Broker 1]: Finished unloading __consumer_offsets-19. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)[2020-04-11 03:02:32,047] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions base_registerAndCardAdd-26 (kafka.server.ReplicaFetcherManager)[2020-04-11 03:02:32,047] INFO [ReplicaFetcherManager on broker 1] Added fetcher for partitions List([base_registerAndCardAdd-26, initOffset 18734 to broker BrokerEndPoint(2,19.13.139.125,9092)] ) (kafka.server.ReplicaFetcherManager)[2020-04-11 03:02:32,055] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions mac-base-topic-15 (kafka.server.ReplicaFetcherManager)[2020-04-11 03:02:32,055] INFO [ReplicaFetcherManager on broker 1] Added fetcher for partitions List([mac-base-topic-15, initOffset 82535 to broker BrokerEndPoint(2,19.13.139.125,9092)] ) (kafka.server.ReplicaFetcherManager)[2020-04-11 03:02:32,061] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions pay-total-order-topic-24 (kafka.server.ReplicaFetcherManager)[2020-04-11 03:02:32,061] INFO [ReplicaFetcherManager on broker 1] Added fetcher for partitions List([pay-total-order-topic-24, initOffset 83078 to broker BrokerEndPoint(2,19.13.139.125,9092)] ) (kafka.server.ReplicaFetcherManager)
zk is ok。
> Error is reported until the cluster is restarted. Error for partition [__consumer_offsets,19] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition.
> ---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-9870
> URL: https://issues.apache.org/jira/browse/KAFKA-9870
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 0.11.0.0
> Environment: jdk 1.8
> Reporter: yonglu gao
> Priority: Major
>
> I have a kafka cluster .when broker 2 restart,then error,Error is reported until the cluster is restarted in turn after 3 hours:
>
> broker2:
> ERROR [KafkaApi-2] Error when handling request \{replica_id=0,max_wait_time=500,min_bytes=1,max_bytes=10485760,isolation_level=0,topics=[{topic=__consumer_offsets,partitions=[{partition=13,fetch_offset=17465556,log_start_offset=0,max_bytes=1048576}]}]} (kafka.server.KafkaApis)RROR [KafkaApi-2] Error when handling request \{replica_id=0,max_wait_time=500,min_bytes=1,max_bytes=10485760,isolation_level=0,topics=[{topic=__consumer_offsets,partitions=[{partition=13,fetch_offset=17465556,log_start_offset=0,max_bytes=1048576}]}]} (kafka.server.KafkaApis)kafka.common.NotAssignedReplicaException: Leader 2 failed to record follower 0's position -1 since the replica is not recognized to be one of the assigned replicas for partition __consumer_offsets-13. at kafka.cluster.Partition.updateReplicaLogReadResult(Partition.scala:274)
>
> [2020-04-11 03:01:45,760] INFO Partition [__consumer_offsets,13] on broker 2: Shrinking ISR from 2,1,0 to 2 (kafka.cluster.Partition)
> [2020-04-11 03:02:32,046] ERROR [ReplicaFetcherThread-0-0]: Error for partition [__consumer_offsets,19] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
> [2020-04-11 03:02:32,053] ERROR [ReplicaFetcherThread-0-0]: Error for partition [base_registerAndCardAdd,26] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
> [2020-04-11 03:02:32,059] ERROR [ReplicaFetcherThread-0-0]: Error for partition [mac-base-topic,15] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
> [2020-04-11 03:02:32,067] ERROR [ReplicaFetcherThread-0-0]: Error for partition [pay-total-order-topic,24] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
> [2020-04-11 03:02:32,072] ERROR [ReplicaFetcherThread-0-0]: Error for partition [pay-total-order-topic,30] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
> [2020-04-11 03:02:32,078] ERROR [ReplicaFetcherThread-0-0]: Error for partition [base_registerAndCardAdd,56] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
> [2020-04-11 03:02:32,087] ERROR [ReplicaFetcherThread-0-0]: Error for partition [mac-dbasync-topic,45] to broker 0:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
> *All of these are errors until you restart the cluster*
> * broker0&1:*
> 2020-04-11 03:02:05,261] WARN [ReplicaFetcherThread-0-2]: Error in fetch to broker 2, request (type=FetchRequest, replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={__consumer_offsets-13=(offset=17477531, logStartOffset=0, maxBytes=1048576)}) (kafka.server.ReplicaFetcherThread)
> java.io.IOException: Connection to 2 was disconnected before the response was read
> at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:93)
> at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:93)
> at kafka.server.ReplicaFetcherThread.fetch(ReplicaFetcherThread.scala:207)
> at kafka.server.ReplicaFetcherThread.fetch(ReplicaFetcherThread.scala:42)
> at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:151)
> at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:112)
> at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
> [2020-04-11 03:02:32,041] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions __consumer_offsets-19 (kafka.server.ReplicaFetcherManager)
> [2020-04-11 03:02:32,041] INFO [ReplicaFetcherManager on broker 1] Added fetcher for partitions List([__consumer_offsets-19, initOffset 0 to broker BrokerEndPoint(2,19.13.139.125,9092)] ) (kafka.server.ReplicaFetcherManager)
> [2020-04-11 03:02:32,041] INFO [Group Metadata Manager on Broker 1]: Scheduling unloading of offsets and group metadata from __consumer_offsets-19 (kafka.coordinator.group.GroupMetadataManager)
> [2020-04-11 03:02:32,041] INFO [Group Metadata Manager on Broker 1]: Finished unloading __consumer_offsets-19. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
> [2020-04-11 03:02:32,047] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions base_registerAndCardAdd-26 (kafka.server.ReplicaFetcherManager)
> [2020-04-11 03:02:32,047] INFO [ReplicaFetcherManager on broker 1] Added fetcher for partitions List([base_registerAndCardAdd-26, initOffset 18734 to broker BrokerEndPoint(2,19.13.139.125,9092)] ) (kafka.server.ReplicaFetcherManager)
> [202
>
>
> zk is ok。
--
This message was sent by Atlassian Jira
(v8.3.4#803005)