[
https://issues.apache.org/jira/browse/KAFKA-13564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhenChun Pan updated KAFKA-13564:
---------------------------------
Description:
The machine of broker0 dropped, and some partition change the leader to
broker1. We can found message like below in state-change.log:
[2021-12-11 15:34:14,868] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=3, leader=1, leaderEpoch=8, isr=[1],
zkVersion**{*}{{*}}{{*}}#{*}#{{*}}{*}***, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 3 with correlation id 0 (state.change.logger)
But we found server.log keep print logs like below:
[2021-12-11 15:34:30,272] INFO [ReplicaFetcher replicaId=0, leaderId=1,
fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
And the producer also can not work and the client print messages below:
[2021-12-11 16:00:00,703] INFO [ReplicaFetcher replicaId=0, leaderId=1,
fetcherId=4] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
We begin to resume broker0 at the time 2021-12-11 15:33:10, but did not work.
So we restart all brokers of kafka cluster at the time 2021-12-11 16:32:31, and
fix the trouble.
The log of ceae-1002-flink-characteristic-instance-data-0 below:
搜索 "ceae-1002-flink-characteristic-instance-data-0" （1个文件中匹配到3449次，总计查找1次）
\20211211kafka不选举leader问题\broker0\server.log （匹配3449次）
行 40502: [2021-12-11 15:34:00,283] INFO [Log
partition=ceae-1002-flink-characteristic-instance-data-0,
dir=/opt/kafka-service/data] Recovering unflushed segment 0 (kafka.log.Log)
行 40503: [2021-12-11 15:34:00,283] INFO [Log
partition=ceae-1002-flink-characteristic-instance-data-0,
dir=/opt/kafka-service/data] Loading producer state till offset 0 with message
format version****{*}#{*}#***** (kafka.log.Log)
行 40570: [2021-12-11 15:34:00,542] INFO [ProducerStateManager
partition=ceae-1002-flink-characteristic-instance-data-0] Writing producer
snapshot at offset 82323 (kafka.log.ProducerStateManager)
行 40577: [2021-12-11 15:34:00,566] INFO [Log
partition=ceae-1002-flink-characteristic-instance-data-0,
dir=/opt/kafka-service/data] Loading producer state till offset 82323 with
message format version****{*}#{*}#***** (kafka.log.Log)
行 40578: [2021-12-11 15:34:00,567] INFO [ProducerStateManager
partition=ceae-1002-flink-characteristic-instance-data-0] Loading producer
state from snapshot file
'/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0/00000000000000082323.snapshot'
(kafka.log.ProducerStateManager)
行 40578: [2021-12-11 15:34:00,567] INFO [ProducerStateManager
partition=ceae-1002-flink-characteristic-instance-data-0] Loading producer
state from snapshot file
'/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0/00000000000000082323.snapshot'
(kafka.log.ProducerStateManager)
行 40581: [2021-12-11 15:34:00,568] INFO Completed load of
Log(dir=/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0,
topic=ceae-1002-flink-characteristic-instance-data, partition=0,
highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=82323) with
1 segments in 287ms (437/487 loaded in /opt/kafka-service/data)
(kafka.log.LogManager)
行 41109: [2021-12-11 15:34:17,641] INFO [Partition
ceae-1002-flink-characteristic-instance-data-0 broker=0] Log loaded for
partition ceae-1002-flink-characteristic-instance-data-0 with initial high
watermark 82323 (kafka.cluster.Partition)
行 41109: [2021-12-11 15:34:17,641] INFO [Partition
ceae-1002-flink-characteristic-instance-data-0 broker=0] Log loaded for
partition ceae-1002-flink-characteristic-instance-data-0 with initial high
watermark 82323 (kafka.cluster.Partition)
行 41832: [2021-12-11 15:34:26,032] INFO [ReplicaFetcherManager on broker 0]
Added fetcher to broker 1 for partitions
HashMap(ceae-1002-flink-characteristic-instance-data-0 -> (offset=82323,
leaderEpoch=8), topic-1002-sia-analysed-alarms-8 -> (offset=0, leaderEpoch=7),
cea-1002-event-output-0 -> (offset=0, leaderEpoch=7),
ceae-1002-flink-suppression-message-9 -> (offset=0, leaderEpoch=7))
(kafka.server.ReplicaFetcherManager)
行 41848: [2021-12-11 15:34:26,112] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 42034: [2021-12-11 15:34:27,171] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 42152: [2021-12-11 15:34:28,201] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 42305: [2021-12-11 15:34:29,212] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
。。。。。。。。。。。。。。
行 122789: [2021-12-11 16:30:01,126] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 122813: [2021-12-11 16:30:02,135] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 122839: [2021-12-11 16:30:03,152] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 125359: [2021-12-11 16:31:48,031] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 125383: [2021-12-11 16:31:49,036] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 125408: [2021-12-11 16:31:50,045] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 125432: [2021-12-11 16:31:51,062] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 127446: [2021-12-11 16:32:45,251] INFO [Log
partition=ceae-1002-flink-characteristic-instance-data-0,
dir=/opt/kafka-service/data] Recovering unflushed segment 0 (kafka.log.Log)
行 127447: [2021-12-11 16:32:45,252] INFO [Log
partition=ceae-1002-flink-characteristic-instance-data-0,
dir=/opt/kafka-service/data] Loading producer state till offset 0 with message
format version****{*}#{*}#***** (kafka.log.Log)
行 127517: [2021-12-11 16:32:45,405] INFO [ProducerStateManager
partition=ceae-1002-flink-characteristic-instance-data-0] Writing producer
snapshot at offset 82323 (kafka.log.ProducerStateManager)
行 127518: [2021-12-11 16:32:45,414] INFO [Log
partition=ceae-1002-flink-characteristic-instance-data-0,
dir=/opt/kafka-service/data] Loading producer state till offset 82323 with
message format version****{*}#{*}#***** (kafka.log.Log)
行 127519: [2021-12-11 16:32:45,415] INFO [ProducerStateManager
partition=ceae-1002-flink-characteristic-instance-data-0] Loading producer
state from snapshot file
'/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0/00000000000000082323.snapshot'
(kafka.log.ProducerStateManager)
行 127519: [2021-12-11 16:32:45,415] INFO [ProducerStateManager
partition=ceae-1002-flink-characteristic-instance-data-0] Loading producer
state from snapshot file
'/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0/00000000000000082323.snapshot'
(kafka.log.ProducerStateManager)
行 127520: [2021-12-11 16:32:45,416] INFO Completed load of
Log(dir=/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0,
topic=ceae-1002-flink-characteristic-instance-data, partition=0,
highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=82323) with
1 segments in 166ms (437/487 loaded in /opt/kafka-service/data)
(kafka.log.LogManager)
行 128177: [2021-12-11 16:32:59,045] INFO [Partition
ceae-1002-flink-characteristic-instance-data-0 broker=0] Log loaded for
partition ceae-1002-flink-characteristic-instance-data-0 with initial high
watermark 82323 (kafka.cluster.Partition)
行 128177: [2021-12-11 16:32:59,045] INFO [Partition
ceae-1002-flink-characteristic-instance-data-0 broker=0] Log loaded for
partition ceae-1002-flink-characteristic-instance-data-0 with initial high
watermark 82323 (kafka.cluster.Partition)
行 129436: [2021-12-11 16:33:02,451] INFO [ReplicaFetcherManager on broker
0] Added fetcher to broker 1 for partitions
HashMap(ceae-1002-flink-characteristic-instance-data-0 -> (offset=82323,
leaderEpoch=10), topic-1002-sia-analysed-alarms-8 -> (offset=0,
leaderEpoch=10), cea-1002-event-output-0 -> (offset=0, leaderEpoch=10),
ceae-1002-flink-suppression-message-9 -> (offset=0, leaderEpoch=10))
(kafka.server.ReplicaFetcherManager)
行 129470: [2021-12-11 16:33:02,535] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
UNKNOWN_LEADER_EPOCH (kafka.server.ReplicaFetcherThread)
行 129754: [2021-12-11 16:33:03,762] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
UNKNOWN_LEADER_EPOCH (kafka.server.ReplicaFetcherThread)
行 129941: [2021-12-11 16:33:04,834] INFO [Log
partition=ceae-1002-flink-characteristic-instance-data-0,
dir=/opt/kafka-service/data] Truncating to 82323 has no effect as the largest
offset in the log is 82322 (kafka.log.Log)
搜索 "ceae-1002-flink-characteristic-instance-data-0" （1个文件中匹配到30次，总计查找1次）
20211211kafka不选举leader问题\broker0\state-change.log （匹配30次）
行 272: [2021-12-11 15:34:14,868] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=3, leader=1, leaderEpoch=8, isr=[1],
zkVersion****{*}#{*}#*****, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 3 with correlation id 0 (state.change.logger)
行 1438: [2021-12-11 15:34:17,025] TRACE [Broker id=0] Handling LeaderAndIsr
request correlationId 1 from controller 2 epoch 3 starting the become-follower
transition for partition ceae-1002-flink-characteristic-instance-data-0 with
leader 1 (state.change.logger)
行 1925: [2021-12-11 15:34:17,642] INFO [Broker id=0] Follower
ceae-1002-flink-characteristic-instance-data-0 starts at leader epoch 8 from
offset 82323 with high watermark 82323. Previous leader epoch was -1.
(state.change.logger)
行 2413: [2021-12-11 15:34:30,448] TRACE [Broker id=0] Completed
LeaderAndIsr request correlationId 1 from controller 2 epoch 3 for the
become-follower transition for partition
ceae-1002-flink-characteristic-instance-data-0 with leader 1
(state.change.logger)
行 3301: [2021-12-11 15:34:31,584] INFO [Broker id=0] Ignoring LeaderAndIsr
request from controller 2 with correlation id 2 epoch 3 for partition
ceae-1002-flink-characteristic-instance-data-0 since its associated leader
epoch 8 matches the current leader epoch (state.change.logger)
行 3793: [2021-12-11 15:34:32,343] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=3, leader=1, leaderEpoch=8, isr=[1],
zkVersion****{*}#{*}#*****, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 3 with correlation id 3 (state.change.logger)
行 5470: [2021-12-11 16:32:57,544] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=4, leader=-1, leaderEpoch=9, isr=[1],
zkVersion****{*}#{*}#*****, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 4 with correlation id 0 (state.change.logger)
行 6636: [2021-12-11 16:32:58,712] TRACE [Broker id=0] Handling LeaderAndIsr
request correlationId 1 from controller 2 epoch 4 starting the become-follower
transition for partition ceae-1002-flink-characteristic-instance-data-0 with
leader -1 (state.change.logger)
行 7123: [2021-12-11 16:32:59,045] ERROR [Broker id=0] Received
LeaderAndIsrRequest with correlation id 1 from controller 2 epoch 4 for
partition ceae-1002-flink-characteristic-instance-data-0 (last update
controller epoch 4) but cannot become follower since the new leader -1 is
unavailable. (state.change.logger)
行 7611: [2021-12-11 16:33:01,061] TRACE [Broker id=0] Completed
LeaderAndIsr request correlationId 1 from controller 2 epoch 4 for the
become-follower transition for partition
ceae-1002-flink-characteristic-instance-data-0 with leader -1
(state.change.logger)
行 8103: [2021-12-11 16:33:01,403] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=4, leader=-1, leaderEpoch=9, isr=[1],
zkVersion****{*}#{*}#*****, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 4 with correlation id 2 (state.change.logger)
行 8737: [2021-12-11 16:33:01,758] TRACE [Broker id=0] Handling LeaderAndIsr
request correlationId 3 from controller 2 epoch 4 starting the become-follower
transition for partition ceae-1002-flink-characteristic-instance-data-0 with
leader 1 (state.change.logger)
行 8930: [2021-12-11 16:33:01,839] INFO [Broker id=0] Follower
ceae-1002-flink-characteristic-instance-data-0 starts at leader epoch 10 from
offset 82323 with high watermark 82323. Previous leader epoch was -1.
(state.change.logger)
行 9124: [2021-12-11 16:33:02,974] TRACE [Broker id=0] Completed
LeaderAndIsr request correlationId 3 from controller 2 epoch 4 for the
become-follower transition for partition
ceae-1002-flink-characteristic-instance-data-0 with leader 1
(state.change.logger)
行 9384: [2021-12-11 16:33:03,133] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=4, leader=1, leaderEpoch=10, isr=[1],
zkVersion****{*}#{*}#*****, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 4 with correlation id 4 (state.change.logger)
行 10534: [2021-12-11 16:33:05,471] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=4, leader=1, leaderEpoch=10, isr=[1, 0],
zkVersion****{*}#{*}#*****, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 4 with correlation id 49
(state.change.logger)
行 10945: [2021-12-11 16:38:02,874] TRACE [Broker id=0] Handling
LeaderAndIsr request correlationId 74 from controller 2 epoch 4 starting the
become-leader transition for partition
ceae-1002-flink-characteristic-instance-data-0 (state.change.logger)
行 11126: [2021-12-11 16:38:03,295] INFO [Broker id=0] Leader
ceae-1002-flink-characteristic-instance-data-0 starts at leader epoch 11 from
offset 82593 with high watermark 82593 ISR [1,0] addingReplicas []
removingReplicas []. Previous leader epoch was 10. (state.change.logger)
行 11306: [2021-12-11 16:38:04,265] TRACE [Broker id=0] Completed
LeaderAndIsr request correlationId 74 from controller 2 epoch 4 for the
become-leader transition for partition
ceae-1002-flink-characteristic-instance-data-0 (state.change.logger)
行 11500: [2021-12-11 16:38:04,565] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=4, leader=0, leaderEpoch=11, isr=[1, 0],
zkVersion****{*}#{*}#*****, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 4 with correlation id 75
(state.change.logger)
搜索 "ceae-1002-flink-characteristic-instance-data-0" （1个文件中匹配到17次，总计查找1次）
20211211kafka不选举leader问题\broker2\controller.log （匹配17次）
行 889: [2021-12-11 15:41:31,186] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 898: [2021-12-11 15:46:31,192] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 907: [2021-12-11 15:51:31,201] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 916: [2021-12-11 15:56:31,207] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 925: [2021-12-11 16:01:31,212] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 934: [2021-12-11 16:06:31,219] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 943: [2021-12-11 16:11:31,227] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 952: [2021-12-11 16:16:31,235] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 961: [2021-12-11 16:21:31,240] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 970: [2021-12-11 16:26:31,247] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 979: [2021-12-11 16:31:31,252] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 1801: [2021-12-11 16:33:05,074] DEBUG [Controller id=2] Updating ISRs for
partitions: Set(topic-datasource-access-NetcareLiteKPI-1002-3,
cea-1002-event-base-0, IES.tunnel.eventext.1002-6, IES.tunnel.alarm.1002-9,
ceae-1002-event-base-10, cea-1002-config-model-7, IES.tunnel.motypeevent-7,
IES.tunnel.syncevent.1002-10, ceae-1002-event-output-1, IES.tunnel.dts.1002-8,
dispatch_alarm_topic-8, ceae-1002-flink-characteristic-instance-data-0,
dispatch_alarm_topic-3, ceae-1002-event-output-5, IES.tunnel.syncevent.1002-2,
ceae-1002-flink-suppression-message-9, Notify_IES_Common_Customer-8).
(kafka.controller.KafkaController)
行 1812: [2021-12-11 16:33:05,118] DEBUG [Controller id=2] ISR for partition
ceae-1002-flink-characteristic-instance-data-0 updated to [1,0] and
zkVersion****{*}#{*}#***** (kafka.controller.KafkaController)
行 2068: [2021-12-11 16:38:02,885] INFO [Controller id=2] Partition
ceae-1002-flink-characteristic-instance-data-0 completed preferred replica
leader election. New leader is 0 (kafka.controller.KafkaController)
was:
The machine of broker0 dropped, and some partition change the leader to
broker1. We can found message like below in state-change.log:
[2021-12-11 15:34:14,868] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=3, leader=1, leaderEpoch=8, isr=[1],
zkVersion***{*}{{*}}#{*}#{*}****, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 3 with correlation id 0 (state.change.logger)
But we found server.log keep print logs like below:
[2021-12-11 15:34:30,272] INFO [ReplicaFetcher replicaId=0, leaderId=1,
fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
And the producer also can not work and the client print messages below:
[2021-12-11 16:00:00,703] INFO [ReplicaFetcher replicaId=0, leaderId=1,
fetcherId=4] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
We begin to resume broker0 at the time 2021-12-11 15:33:10, but did not work.
So we restart all brokers of kafka cluster at the time 2021-12-11 16:32:31, and
fix the trouble.
The log of ceae-1002-flink-characteristic-instance-data-0 below:
搜索 "ceae-1002-flink-characteristic-instance-data-0" （1个文件中匹配到3449次，总计查找1次）
\20211211kafka不选举leader问题\节点日志1\server.log （匹配3449次）
行 40502: [2021-12-11 15:34:00,283] INFO [Log
partition=ceae-1002-flink-characteristic-instance-data-0,
dir=/opt/kafka-service/data] Recovering unflushed segment 0 (kafka.log.Log)
行 40503: [2021-12-11 15:34:00,283] INFO [Log
partition=ceae-1002-flink-characteristic-instance-data-0,
dir=/opt/kafka-service/data] Loading producer state till offset 0 with message
format version*****#*#***** (kafka.log.Log)
行 40570: [2021-12-11 15:34:00,542] INFO [ProducerStateManager
partition=ceae-1002-flink-characteristic-instance-data-0] Writing producer
snapshot at offset 82323 (kafka.log.ProducerStateManager)
行 40577: [2021-12-11 15:34:00,566] INFO [Log
partition=ceae-1002-flink-characteristic-instance-data-0,
dir=/opt/kafka-service/data] Loading producer state till offset 82323 with
message format version*****#*#***** (kafka.log.Log)
行 40578: [2021-12-11 15:34:00,567] INFO [ProducerStateManager
partition=ceae-1002-flink-characteristic-instance-data-0] Loading producer
state from snapshot file
'/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0/00000000000000082323.snapshot'
(kafka.log.ProducerStateManager)
行 40578: [2021-12-11 15:34:00,567] INFO [ProducerStateManager
partition=ceae-1002-flink-characteristic-instance-data-0] Loading producer
state from snapshot file
'/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0/00000000000000082323.snapshot'
(kafka.log.ProducerStateManager)
行 40581: [2021-12-11 15:34:00,568] INFO Completed load of
Log(dir=/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0,
topic=ceae-1002-flink-characteristic-instance-data, partition=0,
highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=82323) with
1 segments in 287ms (437/487 loaded in /opt/kafka-service/data)
(kafka.log.LogManager)
行 41109: [2021-12-11 15:34:17,641] INFO [Partition
ceae-1002-flink-characteristic-instance-data-0 broker=0] Log loaded for
partition ceae-1002-flink-characteristic-instance-data-0 with initial high
watermark 82323 (kafka.cluster.Partition)
行 41109: [2021-12-11 15:34:17,641] INFO [Partition
ceae-1002-flink-characteristic-instance-data-0 broker=0] Log loaded for
partition ceae-1002-flink-characteristic-instance-data-0 with initial high
watermark 82323 (kafka.cluster.Partition)
行 41832: [2021-12-11 15:34:26,032] INFO [ReplicaFetcherManager on broker 0]
Added fetcher to broker 1 for partitions
HashMap(ceae-1002-flink-characteristic-instance-data-0 -> (offset=82323,
leaderEpoch=8), topic-1002-sia-analysed-alarms-8 -> (offset=0, leaderEpoch=7),
cea-1002-event-output-0 -> (offset=0, leaderEpoch=7),
ceae-1002-flink-suppression-message-9 -> (offset=0, leaderEpoch=7))
(kafka.server.ReplicaFetcherManager)
行 41848: [2021-12-11 15:34:26,112] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 42034: [2021-12-11 15:34:27,171] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 42152: [2021-12-11 15:34:28,201] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 42305: [2021-12-11 15:34:29,212] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
。。。。。。。。。。。。。。
行 122789: [2021-12-11 16:30:01,126] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 122813: [2021-12-11 16:30:02,135] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 122839: [2021-12-11 16:30:03,152] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 125359: [2021-12-11 16:31:48,031] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 125383: [2021-12-11 16:31:49,036] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 125408: [2021-12-11 16:31:50,045] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 125432: [2021-12-11 16:31:51,062] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
行 127446: [2021-12-11 16:32:45,251] INFO [Log
partition=ceae-1002-flink-characteristic-instance-data-0,
dir=/opt/kafka-service/data] Recovering unflushed segment 0 (kafka.log.Log)
行 127447: [2021-12-11 16:32:45,252] INFO [Log
partition=ceae-1002-flink-characteristic-instance-data-0,
dir=/opt/kafka-service/data] Loading producer state till offset 0 with message
format version*****#*#***** (kafka.log.Log)
行 127517: [2021-12-11 16:32:45,405] INFO [ProducerStateManager
partition=ceae-1002-flink-characteristic-instance-data-0] Writing producer
snapshot at offset 82323 (kafka.log.ProducerStateManager)
行 127518: [2021-12-11 16:32:45,414] INFO [Log
partition=ceae-1002-flink-characteristic-instance-data-0,
dir=/opt/kafka-service/data] Loading producer state till offset 82323 with
message format version*****#*#***** (kafka.log.Log)
行 127519: [2021-12-11 16:32:45,415] INFO [ProducerStateManager
partition=ceae-1002-flink-characteristic-instance-data-0] Loading producer
state from snapshot file
'/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0/00000000000000082323.snapshot'
(kafka.log.ProducerStateManager)
行 127519: [2021-12-11 16:32:45,415] INFO [ProducerStateManager
partition=ceae-1002-flink-characteristic-instance-data-0] Loading producer
state from snapshot file
'/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0/00000000000000082323.snapshot'
(kafka.log.ProducerStateManager)
行 127520: [2021-12-11 16:32:45,416] INFO Completed load of
Log(dir=/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0,
topic=ceae-1002-flink-characteristic-instance-data, partition=0,
highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=82323) with
1 segments in 166ms (437/487 loaded in /opt/kafka-service/data)
(kafka.log.LogManager)
行 128177: [2021-12-11 16:32:59,045] INFO [Partition
ceae-1002-flink-characteristic-instance-data-0 broker=0] Log loaded for
partition ceae-1002-flink-characteristic-instance-data-0 with initial high
watermark 82323 (kafka.cluster.Partition)
行 128177: [2021-12-11 16:32:59,045] INFO [Partition
ceae-1002-flink-characteristic-instance-data-0 broker=0] Log loaded for
partition ceae-1002-flink-characteristic-instance-data-0 with initial high
watermark 82323 (kafka.cluster.Partition)
行 129436: [2021-12-11 16:33:02,451] INFO [ReplicaFetcherManager on broker
0] Added fetcher to broker 1 for partitions
HashMap(ceae-1002-flink-characteristic-instance-data-0 -> (offset=82323,
leaderEpoch=10), topic-1002-sia-analysed-alarms-8 -> (offset=0,
leaderEpoch=10), cea-1002-event-output-0 -> (offset=0, leaderEpoch=10),
ceae-1002-flink-suppression-message-9 -> (offset=0, leaderEpoch=10))
(kafka.server.ReplicaFetcherManager)
行 129470: [2021-12-11 16:33:02,535] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
UNKNOWN_LEADER_EPOCH (kafka.server.ReplicaFetcherThread)
行 129754: [2021-12-11 16:33:03,762] INFO [ReplicaFetcher replicaId=0,
leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
ceae-1002-flink-characteristic-instance-data-0 as the leader reported an error:
UNKNOWN_LEADER_EPOCH (kafka.server.ReplicaFetcherThread)
行 129941: [2021-12-11 16:33:04,834] INFO [Log
partition=ceae-1002-flink-characteristic-instance-data-0,
dir=/opt/kafka-service/data] Truncating to 82323 has no effect as the largest
offset in the log is 82322 (kafka.log.Log)
搜索 "ceae-1002-flink-characteristic-instance-data-0" （1个文件中匹配到30次，总计查找1次）
20211211kafka不选举leader问题\节点日志1\state-change.log （匹配30次）
行 272: [2021-12-11 15:34:14,868] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=3, leader=1, leaderEpoch=8, isr=[1],
zkVersion*****#*#*****, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 3 with correlation id 0 (state.change.logger)
行 1438: [2021-12-11 15:34:17,025] TRACE [Broker id=0] Handling LeaderAndIsr
request correlationId 1 from controller 2 epoch 3 starting the become-follower
transition for partition ceae-1002-flink-characteristic-instance-data-0 with
leader 1 (state.change.logger)
行 1925: [2021-12-11 15:34:17,642] INFO [Broker id=0] Follower
ceae-1002-flink-characteristic-instance-data-0 starts at leader epoch 8 from
offset 82323 with high watermark 82323. Previous leader epoch was -1.
(state.change.logger)
行 2413: [2021-12-11 15:34:30,448] TRACE [Broker id=0] Completed
LeaderAndIsr request correlationId 1 from controller 2 epoch 3 for the
become-follower transition for partition
ceae-1002-flink-characteristic-instance-data-0 with leader 1
(state.change.logger)
行 3301: [2021-12-11 15:34:31,584] INFO [Broker id=0] Ignoring LeaderAndIsr
request from controller 2 with correlation id 2 epoch 3 for partition
ceae-1002-flink-characteristic-instance-data-0 since its associated leader
epoch 8 matches the current leader epoch (state.change.logger)
行 3793: [2021-12-11 15:34:32,343] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=3, leader=1, leaderEpoch=8, isr=[1],
zkVersion*****#*#*****, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 3 with correlation id 3 (state.change.logger)
行 5470: [2021-12-11 16:32:57,544] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=4, leader=-1, leaderEpoch=9, isr=[1],
zkVersion*****#*#*****, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 4 with correlation id 0 (state.change.logger)
行 6636: [2021-12-11 16:32:58,712] TRACE [Broker id=0] Handling LeaderAndIsr
request correlationId 1 from controller 2 epoch 4 starting the become-follower
transition for partition ceae-1002-flink-characteristic-instance-data-0 with
leader -1 (state.change.logger)
行 7123: [2021-12-11 16:32:59,045] ERROR [Broker id=0] Received
LeaderAndIsrRequest with correlation id 1 from controller 2 epoch 4 for
partition ceae-1002-flink-characteristic-instance-data-0 (last update
controller epoch 4) but cannot become follower since the new leader -1 is
unavailable. (state.change.logger)
行 7611: [2021-12-11 16:33:01,061] TRACE [Broker id=0] Completed
LeaderAndIsr request correlationId 1 from controller 2 epoch 4 for the
become-follower transition for partition
ceae-1002-flink-characteristic-instance-data-0 with leader -1
(state.change.logger)
行 8103: [2021-12-11 16:33:01,403] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=4, leader=-1, leaderEpoch=9, isr=[1],
zkVersion*****#*#*****, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 4 with correlation id 2 (state.change.logger)
行 8737: [2021-12-11 16:33:01,758] TRACE [Broker id=0] Handling LeaderAndIsr
request correlationId 3 from controller 2 epoch 4 starting the become-follower
transition for partition ceae-1002-flink-characteristic-instance-data-0 with
leader 1 (state.change.logger)
行 8930: [2021-12-11 16:33:01,839] INFO [Broker id=0] Follower
ceae-1002-flink-characteristic-instance-data-0 starts at leader epoch 10 from
offset 82323 with high watermark 82323. Previous leader epoch was -1.
(state.change.logger)
行 9124: [2021-12-11 16:33:02,974] TRACE [Broker id=0] Completed
LeaderAndIsr request correlationId 3 from controller 2 epoch 4 for the
become-follower transition for partition
ceae-1002-flink-characteristic-instance-data-0 with leader 1
(state.change.logger)
行 9384: [2021-12-11 16:33:03,133] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=4, leader=1, leaderEpoch=10, isr=[1],
zkVersion*****#*#*****, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 4 with correlation id 4 (state.change.logger)
行 10534: [2021-12-11 16:33:05,471] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=4, leader=1, leaderEpoch=10, isr=[1, 0],
zkVersion*****#*#*****, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 4 with correlation id 49
(state.change.logger)
行 10945: [2021-12-11 16:38:02,874] TRACE [Broker id=0] Handling
LeaderAndIsr request correlationId 74 from controller 2 epoch 4 starting the
become-leader transition for partition
ceae-1002-flink-characteristic-instance-data-0 (state.change.logger)
行 11126: [2021-12-11 16:38:03,295] INFO [Broker id=0] Leader
ceae-1002-flink-characteristic-instance-data-0 starts at leader epoch 11 from
offset 82593 with high watermark 82593 ISR [1,0] addingReplicas []
removingReplicas []. Previous leader epoch was 10. (state.change.logger)
行 11306: [2021-12-11 16:38:04,265] TRACE [Broker id=0] Completed
LeaderAndIsr request correlationId 74 from controller 2 epoch 4 for the
become-leader transition for partition
ceae-1002-flink-characteristic-instance-data-0 (state.change.logger)
行 11500: [2021-12-11 16:38:04,565] TRACE [Broker id=0] Cached leader info
UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
partitionIndex=0, controllerEpoch=4, leader=0, leaderEpoch=11, isr=[1, 0],
zkVersion*****#*#*****, offlineReplicas=[]) for partition
ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
request sent by controller 2 epoch 4 with correlation id 75
(state.change.logger)
搜索 "ceae-1002-flink-characteristic-instance-data-0" （1个文件中匹配到17次，总计查找1次）
20211211kafka不选举leader问题\节点日志3\controller.log （匹配17次）
行 889: [2021-12-11 15:41:31,186] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 898: [2021-12-11 15:46:31,192] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 907: [2021-12-11 15:51:31,201] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 916: [2021-12-11 15:56:31,207] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 925: [2021-12-11 16:01:31,212] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 934: [2021-12-11 16:06:31,219] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 943: [2021-12-11 16:11:31,227] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 952: [2021-12-11 16:16:31,235] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 961: [2021-12-11 16:21:31,240] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 970: [2021-12-11 16:26:31,247] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 979: [2021-12-11 16:31:31,252] DEBUG [Controller id=2] Topics not in
preferred replica for broker 0
HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
Notify_IES_Common_ServiceInstance-3 -> List(0, 1), topic-1002-flink-base-rule-2
-> List(0, 1), IES.tunnel.eventext.1002-4 -> List(0, 1),
Notify_IES_Common_ServiceInstance-9 -> List(0, 1), SID_TroubeEvent-7 -> List(0,
1), IES.tunnel.config.1002-3 -> List(0, 1), ceae-1002-event-overload-1 ->
List(0, 1), IES.tunnel.resource.1002-11 -> List(0, 2), cea-1002-event-nbi-10 ->
List(0, 1), topic-sia-affected-services-6 -> List(0, 1),
topic-1002-flink-config-2 -> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1),
IES.tunnel.syncevent.1002-2 -> List(0, 1), __consumer_offsets-9 -> List(0, 2,
1), topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
ceae-1002-characteristic-instance-7 -> List(0, 1), topic-1002-flink-original-7
-> List(0, 1), topic-1002-sia-filtered-alarms-0 -> List(0, 1),
mateinfo.1002.nfsalarmtopic-6 -> List(0, 1), topic-1002-sia-analysed-alarms-4
-> List(0, 1), IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1),
dispatch_alarm_topic-8 -> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
-> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1), topic-1002-flink-original-1
-> List(0, 1), topic-sia-filtered-alarms-8 -> List(0, 1),
topic-1002-flink-base-rule-8 -> List(0, 1), topic-1002-sia-analysed-alarms-10
-> List(0, 1), ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
行 1801: [2021-12-11 16:33:05,074] DEBUG [Controller id=2] Updating ISRs for
partitions: Set(topic-datasource-access-NetcareLiteKPI-1002-3,
cea-1002-event-base-0, IES.tunnel.eventext.1002-6, IES.tunnel.alarm.1002-9,
ceae-1002-event-base-10, cea-1002-config-model-7, IES.tunnel.motypeevent-7,
IES.tunnel.syncevent.1002-10, ceae-1002-event-output-1, IES.tunnel.dts.1002-8,
dispatch_alarm_topic-8, ceae-1002-flink-characteristic-instance-data-0,
dispatch_alarm_topic-3, ceae-1002-event-output-5, IES.tunnel.syncevent.1002-2,
ceae-1002-flink-suppression-message-9, Notify_IES_Common_Customer-8).
(kafka.controller.KafkaController)
行 1812: [2021-12-11 16:33:05,118] DEBUG [Controller id=2] ISR for partition
ceae-1002-flink-characteristic-instance-data-0 updated to [1,0] and
zkVersion*****#*#***** (kafka.controller.KafkaController)
行 2068: [2021-12-11 16:38:02,885] INFO [Controller id=2] Partition
ceae-1002-flink-characteristic-instance-data-0 completed preferred replica
leader election. New leader is 0 (kafka.controller.KafkaController)
> Kafka keep print NOT_LEADER_OR_FOLLOWER in log file after one broker dropped,
> and the producer can not work.
> ------------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-13564
> URL: https://issues.apache.org/jira/browse/KAFKA-13564
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 2.7.0
> Reporter: ZhenChun Pan
> Priority: Major
>
> The machine of broker0 dropped, and some partition change the leader to
> broker1. We can found message like below in state-change.log:
> [2021-12-11 15:34:14,868] TRACE [Broker id=0] Cached leader info
> UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
> partitionIndex=0, controllerEpoch=3, leader=1, leaderEpoch=8, isr=[1],
> zkVersion**{*}{{*}}{{*}}#{*}#{{*}}{*}***, offlineReplicas=[]) for partition
> ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
> request sent by controller 2 epoch 3 with correlation id 0
> (state.change.logger)
> But we found server.log keep print logs like below:
> [2021-12-11 15:34:30,272] INFO [ReplicaFetcher replicaId=0, leaderId=1,
> fetcherId=6] Retrying leaderEpoch request for partition
> ceae-1002-flink-characteristic-instance-data-0 as the leader reported an
> error: NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
> And the producer also can not work and the client print messages below:
> [2021-12-11 16:00:00,703] INFO [ReplicaFetcher replicaId=0, leaderId=1,
> fetcherId=4] Retrying leaderEpoch request for partition
> ceae-1002-flink-characteristic-instance-data-0 as the leader reported an
> error: NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
> We begin to resume broker0 at the time 2021-12-11 15:33:10, but did not work.
> So we restart all brokers of kafka cluster at the time 2021-12-11 16:32:31,
> and fix the trouble.
> The log of ceae-1002-flink-characteristic-instance-data-0 below:
> 搜索 "ceae-1002-flink-characteristic-instance-data-0" （1个文件中匹配到3449次，总计查找1次）
> \20211211kafka不选举leader问题\broker0\server.log （匹配3449次）
> 行 40502: [2021-12-11 15:34:00,283] INFO [Log
> partition=ceae-1002-flink-characteristic-instance-data-0,
> dir=/opt/kafka-service/data] Recovering unflushed segment 0 (kafka.log.Log)
> 行 40503: [2021-12-11 15:34:00,283] INFO [Log
> partition=ceae-1002-flink-characteristic-instance-data-0,
> dir=/opt/kafka-service/data] Loading producer state till offset 0 with
> message format version****{*}#{*}#***** (kafka.log.Log)
> 行 40570: [2021-12-11 15:34:00,542] INFO [ProducerStateManager
> partition=ceae-1002-flink-characteristic-instance-data-0] Writing producer
> snapshot at offset 82323 (kafka.log.ProducerStateManager)
> 行 40577: [2021-12-11 15:34:00,566] INFO [Log
> partition=ceae-1002-flink-characteristic-instance-data-0,
> dir=/opt/kafka-service/data] Loading producer state till offset 82323 with
> message format version****{*}#{*}#***** (kafka.log.Log)
> 行 40578: [2021-12-11 15:34:00,567] INFO [ProducerStateManager
> partition=ceae-1002-flink-characteristic-instance-data-0] Loading producer
> state from snapshot file
> '/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0/00000000000000082323.snapshot'
> (kafka.log.ProducerStateManager)
> 行 40578: [2021-12-11 15:34:00,567] INFO [ProducerStateManager
> partition=ceae-1002-flink-characteristic-instance-data-0] Loading producer
> state from snapshot file
> '/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0/00000000000000082323.snapshot'
> (kafka.log.ProducerStateManager)
> 行 40581: [2021-12-11 15:34:00,568] INFO Completed load of
> Log(dir=/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0,
> topic=ceae-1002-flink-characteristic-instance-data, partition=0,
> highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=82323)
> with 1 segments in 287ms (437/487 loaded in /opt/kafka-service/data)
> (kafka.log.LogManager)
> 行 41109: [2021-12-11 15:34:17,641] INFO [Partition
> ceae-1002-flink-characteristic-instance-data-0 broker=0] Log loaded for
> partition ceae-1002-flink-characteristic-instance-data-0 with initial high
> watermark 82323 (kafka.cluster.Partition)
> 行 41109: [2021-12-11 15:34:17,641] INFO [Partition
> ceae-1002-flink-characteristic-instance-data-0 broker=0] Log loaded for
> partition ceae-1002-flink-characteristic-instance-data-0 with initial high
> watermark 82323 (kafka.cluster.Partition)
> 行 41832: [2021-12-11 15:34:26,032] INFO [ReplicaFetcherManager on broker
> 0] Added fetcher to broker 1 for partitions
> HashMap(ceae-1002-flink-characteristic-instance-data-0 -> (offset=82323,
> leaderEpoch=8), topic-1002-sia-analysed-alarms-8 -> (offset=0,
> leaderEpoch=7), cea-1002-event-output-0 -> (offset=0, leaderEpoch=7),
> ceae-1002-flink-suppression-message-9 -> (offset=0, leaderEpoch=7))
> (kafka.server.ReplicaFetcherManager)
> 行 41848: [2021-12-11 15:34:26,112] INFO [ReplicaFetcher replicaId=0,
> leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
> ceae-1002-flink-characteristic-instance-data-0 as the leader reported an
> error: NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
> 行 42034: [2021-12-11 15:34:27,171] INFO [ReplicaFetcher replicaId=0,
> leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
> ceae-1002-flink-characteristic-instance-data-0 as the leader reported an
> error: NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
> 行 42152: [2021-12-11 15:34:28,201] INFO [ReplicaFetcher replicaId=0,
> leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
> ceae-1002-flink-characteristic-instance-data-0 as the leader reported an
> error: NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
> 行 42305: [2021-12-11 15:34:29,212] INFO [ReplicaFetcher replicaId=0,
> leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
> ceae-1002-flink-characteristic-instance-data-0 as the leader reported an
> error: NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
> 。。。。。。。。。。。。。。
> 行 122789: [2021-12-11 16:30:01,126] INFO [ReplicaFetcher replicaId=0,
> leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
> ceae-1002-flink-characteristic-instance-data-0 as the leader reported an
> error: NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
> 行 122813: [2021-12-11 16:30:02,135] INFO [ReplicaFetcher replicaId=0,
> leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
> ceae-1002-flink-characteristic-instance-data-0 as the leader reported an
> error: NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
> 行 122839: [2021-12-11 16:30:03,152] INFO [ReplicaFetcher replicaId=0,
> leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
> ceae-1002-flink-characteristic-instance-data-0 as the leader reported an
> error: NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
> 行 125359: [2021-12-11 16:31:48,031] INFO [ReplicaFetcher replicaId=0,
> leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
> ceae-1002-flink-characteristic-instance-data-0 as the leader reported an
> error: NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
> 行 125383: [2021-12-11 16:31:49,036] INFO [ReplicaFetcher replicaId=0,
> leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
> ceae-1002-flink-characteristic-instance-data-0 as the leader reported an
> error: NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
> 行 125408: [2021-12-11 16:31:50,045] INFO [ReplicaFetcher replicaId=0,
> leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
> ceae-1002-flink-characteristic-instance-data-0 as the leader reported an
> error: NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
> 行 125432: [2021-12-11 16:31:51,062] INFO [ReplicaFetcher replicaId=0,
> leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
> ceae-1002-flink-characteristic-instance-data-0 as the leader reported an
> error: NOT_LEADER_OR_FOLLOWER (kafka.server.ReplicaFetcherThread)
> 行 127446: [2021-12-11 16:32:45,251] INFO [Log
> partition=ceae-1002-flink-characteristic-instance-data-0,
> dir=/opt/kafka-service/data] Recovering unflushed segment 0 (kafka.log.Log)
> 行 127447: [2021-12-11 16:32:45,252] INFO [Log
> partition=ceae-1002-flink-characteristic-instance-data-0,
> dir=/opt/kafka-service/data] Loading producer state till offset 0 with
> message format version****{*}#{*}#***** (kafka.log.Log)
> 行 127517: [2021-12-11 16:32:45,405] INFO [ProducerStateManager
> partition=ceae-1002-flink-characteristic-instance-data-0] Writing producer
> snapshot at offset 82323 (kafka.log.ProducerStateManager)
> 行 127518: [2021-12-11 16:32:45,414] INFO [Log
> partition=ceae-1002-flink-characteristic-instance-data-0,
> dir=/opt/kafka-service/data] Loading producer state till offset 82323 with
> message format version****{*}#{*}#***** (kafka.log.Log)
> 行 127519: [2021-12-11 16:32:45,415] INFO [ProducerStateManager
> partition=ceae-1002-flink-characteristic-instance-data-0] Loading producer
> state from snapshot file
> '/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0/00000000000000082323.snapshot'
> (kafka.log.ProducerStateManager)
> 行 127519: [2021-12-11 16:32:45,415] INFO [ProducerStateManager
> partition=ceae-1002-flink-characteristic-instance-data-0] Loading producer
> state from snapshot file
> '/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0/00000000000000082323.snapshot'
> (kafka.log.ProducerStateManager)
> 行 127520: [2021-12-11 16:32:45,416] INFO Completed load of
> Log(dir=/opt/kafka-service/data/ceae-1002-flink-characteristic-instance-data-0,
> topic=ceae-1002-flink-characteristic-instance-data, partition=0,
> highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=82323)
> with 1 segments in 166ms (437/487 loaded in /opt/kafka-service/data)
> (kafka.log.LogManager)
> 行 128177: [2021-12-11 16:32:59,045] INFO [Partition
> ceae-1002-flink-characteristic-instance-data-0 broker=0] Log loaded for
> partition ceae-1002-flink-characteristic-instance-data-0 with initial high
> watermark 82323 (kafka.cluster.Partition)
> 行 128177: [2021-12-11 16:32:59,045] INFO [Partition
> ceae-1002-flink-characteristic-instance-data-0 broker=0] Log loaded for
> partition ceae-1002-flink-characteristic-instance-data-0 with initial high
> watermark 82323 (kafka.cluster.Partition)
> 行 129436: [2021-12-11 16:33:02,451] INFO [ReplicaFetcherManager on broker
> 0] Added fetcher to broker 1 for partitions
> HashMap(ceae-1002-flink-characteristic-instance-data-0 -> (offset=82323,
> leaderEpoch=10), topic-1002-sia-analysed-alarms-8 -> (offset=0,
> leaderEpoch=10), cea-1002-event-output-0 -> (offset=0, leaderEpoch=10),
> ceae-1002-flink-suppression-message-9 -> (offset=0, leaderEpoch=10))
> (kafka.server.ReplicaFetcherManager)
> 行 129470: [2021-12-11 16:33:02,535] INFO [ReplicaFetcher replicaId=0,
> leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
> ceae-1002-flink-characteristic-instance-data-0 as the leader reported an
> error: UNKNOWN_LEADER_EPOCH (kafka.server.ReplicaFetcherThread)
> 行 129754: [2021-12-11 16:33:03,762] INFO [ReplicaFetcher replicaId=0,
> leaderId=1, fetcherId=6] Retrying leaderEpoch request for partition
> ceae-1002-flink-characteristic-instance-data-0 as the leader reported an
> error: UNKNOWN_LEADER_EPOCH (kafka.server.ReplicaFetcherThread)
> 行 129941: [2021-12-11 16:33:04,834] INFO [Log
> partition=ceae-1002-flink-characteristic-instance-data-0,
> dir=/opt/kafka-service/data] Truncating to 82323 has no effect as the largest
> offset in the log is 82322 (kafka.log.Log)
> 搜索 "ceae-1002-flink-characteristic-instance-data-0" （1个文件中匹配到30次，总计查找1次）
> 20211211kafka不选举leader问题\broker0\state-change.log （匹配30次）
> 行 272: [2021-12-11 15:34:14,868] TRACE [Broker id=0] Cached leader info
> UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
> partitionIndex=0, controllerEpoch=3, leader=1, leaderEpoch=8, isr=[1],
> zkVersion****{*}#{*}#*****, offlineReplicas=[]) for partition
> ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
> request sent by controller 2 epoch 3 with correlation id 0
> (state.change.logger)
> 行 1438: [2021-12-11 15:34:17,025] TRACE [Broker id=0] Handling
> LeaderAndIsr request correlationId 1 from controller 2 epoch 3 starting the
> become-follower transition for partition
> ceae-1002-flink-characteristic-instance-data-0 with leader 1
> (state.change.logger)
> 行 1925: [2021-12-11 15:34:17,642] INFO [Broker id=0] Follower
> ceae-1002-flink-characteristic-instance-data-0 starts at leader epoch 8 from
> offset 82323 with high watermark 82323. Previous leader epoch was -1.
> (state.change.logger)
> 行 2413: [2021-12-11 15:34:30,448] TRACE [Broker id=0] Completed
> LeaderAndIsr request correlationId 1 from controller 2 epoch 3 for the
> become-follower transition for partition
> ceae-1002-flink-characteristic-instance-data-0 with leader 1
> (state.change.logger)
> 行 3301: [2021-12-11 15:34:31,584] INFO [Broker id=0] Ignoring
> LeaderAndIsr request from controller 2 with correlation id 2 epoch 3 for
> partition ceae-1002-flink-characteristic-instance-data-0 since its associated
> leader epoch 8 matches the current leader epoch (state.change.logger)
> 行 3793: [2021-12-11 15:34:32,343] TRACE [Broker id=0] Cached leader info
> UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
> partitionIndex=0, controllerEpoch=3, leader=1, leaderEpoch=8, isr=[1],
> zkVersion****{*}#{*}#*****, offlineReplicas=[]) for partition
> ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
> request sent by controller 2 epoch 3 with correlation id 3
> (state.change.logger)
> 行 5470: [2021-12-11 16:32:57,544] TRACE [Broker id=0] Cached leader info
> UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
> partitionIndex=0, controllerEpoch=4, leader=-1, leaderEpoch=9, isr=[1],
> zkVersion****{*}#{*}#*****, offlineReplicas=[]) for partition
> ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
> request sent by controller 2 epoch 4 with correlation id 0
> (state.change.logger)
> 行 6636: [2021-12-11 16:32:58,712] TRACE [Broker id=0] Handling
> LeaderAndIsr request correlationId 1 from controller 2 epoch 4 starting the
> become-follower transition for partition
> ceae-1002-flink-characteristic-instance-data-0 with leader -1
> (state.change.logger)
> 行 7123: [2021-12-11 16:32:59,045] ERROR [Broker id=0] Received
> LeaderAndIsrRequest with correlation id 1 from controller 2 epoch 4 for
> partition ceae-1002-flink-characteristic-instance-data-0 (last update
> controller epoch 4) but cannot become follower since the new leader -1 is
> unavailable. (state.change.logger)
> 行 7611: [2021-12-11 16:33:01,061] TRACE [Broker id=0] Completed
> LeaderAndIsr request correlationId 1 from controller 2 epoch 4 for the
> become-follower transition for partition
> ceae-1002-flink-characteristic-instance-data-0 with leader -1
> (state.change.logger)
> 行 8103: [2021-12-11 16:33:01,403] TRACE [Broker id=0] Cached leader info
> UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
> partitionIndex=0, controllerEpoch=4, leader=-1, leaderEpoch=9, isr=[1],
> zkVersion****{*}#{*}#*****, offlineReplicas=[]) for partition
> ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
> request sent by controller 2 epoch 4 with correlation id 2
> (state.change.logger)
> 行 8737: [2021-12-11 16:33:01,758] TRACE [Broker id=0] Handling
> LeaderAndIsr request correlationId 3 from controller 2 epoch 4 starting the
> become-follower transition for partition
> ceae-1002-flink-characteristic-instance-data-0 with leader 1
> (state.change.logger)
> 行 8930: [2021-12-11 16:33:01,839] INFO [Broker id=0] Follower
> ceae-1002-flink-characteristic-instance-data-0 starts at leader epoch 10 from
> offset 82323 with high watermark 82323. Previous leader epoch was -1.
> (state.change.logger)
> 行 9124: [2021-12-11 16:33:02,974] TRACE [Broker id=0] Completed
> LeaderAndIsr request correlationId 3 from controller 2 epoch 4 for the
> become-follower transition for partition
> ceae-1002-flink-characteristic-instance-data-0 with leader 1
> (state.change.logger)
> 行 9384: [2021-12-11 16:33:03,133] TRACE [Broker id=0] Cached leader info
> UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
> partitionIndex=0, controllerEpoch=4, leader=1, leaderEpoch=10, isr=[1],
> zkVersion****{*}#{*}#*****, offlineReplicas=[]) for partition
> ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
> request sent by controller 2 epoch 4 with correlation id 4
> (state.change.logger)
> 行 10534: [2021-12-11 16:33:05,471] TRACE [Broker id=0] Cached leader info
> UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
> partitionIndex=0, controllerEpoch=4, leader=1, leaderEpoch=10, isr=[1, 0],
> zkVersion****{*}#{*}#*****, offlineReplicas=[]) for partition
> ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
> request sent by controller 2 epoch 4 with correlation id 49
> (state.change.logger)
> 行 10945: [2021-12-11 16:38:02,874] TRACE [Broker id=0] Handling
> LeaderAndIsr request correlationId 74 from controller 2 epoch 4 starting the
> become-leader transition for partition
> ceae-1002-flink-characteristic-instance-data-0 (state.change.logger)
> 行 11126: [2021-12-11 16:38:03,295] INFO [Broker id=0] Leader
> ceae-1002-flink-characteristic-instance-data-0 starts at leader epoch 11 from
> offset 82593 with high watermark 82593 ISR [1,0] addingReplicas []
> removingReplicas []. Previous leader epoch was 10. (state.change.logger)
> 行 11306: [2021-12-11 16:38:04,265] TRACE [Broker id=0] Completed
> LeaderAndIsr request correlationId 74 from controller 2 epoch 4 for the
> become-leader transition for partition
> ceae-1002-flink-characteristic-instance-data-0 (state.change.logger)
> 行 11500: [2021-12-11 16:38:04,565] TRACE [Broker id=0] Cached leader info
> UpdateMetadataPartitionState(topicName='ceae-1002-flink-characteristic-instance-data',
> partitionIndex=0, controllerEpoch=4, leader=0, leaderEpoch=11, isr=[1, 0],
> zkVersion****{*}#{*}#*****, offlineReplicas=[]) for partition
> ceae-1002-flink-characteristic-instance-data-0 in response to UpdateMetadata
> request sent by controller 2 epoch 4 with correlation id 75
> (state.change.logger)
> 搜索 "ceae-1002-flink-characteristic-instance-data-0" （1个文件中匹配到17次，总计查找1次）
> 20211211kafka不选举leader问题\broker2\controller.log （匹配17次）
> 行 889: [2021-12-11 15:41:31,186] DEBUG [Controller id=2] Topics not in
> preferred replica for broker 0
> HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
> IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
> Notify_IES_Common_ServiceInstance-3 -> List(0, 1),
> topic-1002-flink-base-rule-2 -> List(0, 1), IES.tunnel.eventext.1002-4 ->
> List(0, 1), Notify_IES_Common_ServiceInstance-9 -> List(0, 1),
> SID_TroubeEvent-7 -> List(0, 1), IES.tunnel.config.1002-3 -> List(0, 1),
> ceae-1002-event-overload-1 -> List(0, 1), IES.tunnel.resource.1002-11 ->
> List(0, 2), cea-1002-event-nbi-10 -> List(0, 1),
> topic-sia-affected-services-6 -> List(0, 1), topic-1002-flink-config-2 ->
> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1), IES.tunnel.syncevent.1002-2
> -> List(0, 1), __consumer_offsets-9 -> List(0, 2, 1),
> topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
> List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
> ceae-1002-characteristic-instance-7 -> List(0, 1),
> topic-1002-flink-original-7 -> List(0, 1), topic-1002-sia-filtered-alarms-0
> -> List(0, 1), mateinfo.1002.nfsalarmtopic-6 -> List(0, 1),
> topic-1002-sia-analysed-alarms-4 -> List(0, 1),
> IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1), dispatch_alarm_topic-8 ->
> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
> topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
> -> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
> List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1),
> topic-1002-flink-original-1 -> List(0, 1), topic-sia-filtered-alarms-8 ->
> List(0, 1), topic-1002-flink-base-rule-8 -> List(0, 1),
> topic-1002-sia-analysed-alarms-10 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
> IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
> Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
> List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
> 行 898: [2021-12-11 15:46:31,192] DEBUG [Controller id=2] Topics not in
> preferred replica for broker 0
> HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
> IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
> Notify_IES_Common_ServiceInstance-3 -> List(0, 1),
> topic-1002-flink-base-rule-2 -> List(0, 1), IES.tunnel.eventext.1002-4 ->
> List(0, 1), Notify_IES_Common_ServiceInstance-9 -> List(0, 1),
> SID_TroubeEvent-7 -> List(0, 1), IES.tunnel.config.1002-3 -> List(0, 1),
> ceae-1002-event-overload-1 -> List(0, 1), IES.tunnel.resource.1002-11 ->
> List(0, 2), cea-1002-event-nbi-10 -> List(0, 1),
> topic-sia-affected-services-6 -> List(0, 1), topic-1002-flink-config-2 ->
> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1), IES.tunnel.syncevent.1002-2
> -> List(0, 1), __consumer_offsets-9 -> List(0, 2, 1),
> topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
> List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
> ceae-1002-characteristic-instance-7 -> List(0, 1),
> topic-1002-flink-original-7 -> List(0, 1), topic-1002-sia-filtered-alarms-0
> -> List(0, 1), mateinfo.1002.nfsalarmtopic-6 -> List(0, 1),
> topic-1002-sia-analysed-alarms-4 -> List(0, 1),
> IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1), dispatch_alarm_topic-8 ->
> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
> topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
> -> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
> List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1),
> topic-1002-flink-original-1 -> List(0, 1), topic-sia-filtered-alarms-8 ->
> List(0, 1), topic-1002-flink-base-rule-8 -> List(0, 1),
> topic-1002-sia-analysed-alarms-10 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
> IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
> Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
> List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
> 行 907: [2021-12-11 15:51:31,201] DEBUG [Controller id=2] Topics not in
> preferred replica for broker 0
> HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
> IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
> Notify_IES_Common_ServiceInstance-3 -> List(0, 1),
> topic-1002-flink-base-rule-2 -> List(0, 1), IES.tunnel.eventext.1002-4 ->
> List(0, 1), Notify_IES_Common_ServiceInstance-9 -> List(0, 1),
> SID_TroubeEvent-7 -> List(0, 1), IES.tunnel.config.1002-3 -> List(0, 1),
> ceae-1002-event-overload-1 -> List(0, 1), IES.tunnel.resource.1002-11 ->
> List(0, 2), cea-1002-event-nbi-10 -> List(0, 1),
> topic-sia-affected-services-6 -> List(0, 1), topic-1002-flink-config-2 ->
> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1), IES.tunnel.syncevent.1002-2
> -> List(0, 1), __consumer_offsets-9 -> List(0, 2, 1),
> topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
> List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
> ceae-1002-characteristic-instance-7 -> List(0, 1),
> topic-1002-flink-original-7 -> List(0, 1), topic-1002-sia-filtered-alarms-0
> -> List(0, 1), mateinfo.1002.nfsalarmtopic-6 -> List(0, 1),
> topic-1002-sia-analysed-alarms-4 -> List(0, 1),
> IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1), dispatch_alarm_topic-8 ->
> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
> topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
> -> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
> List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1),
> topic-1002-flink-original-1 -> List(0, 1), topic-sia-filtered-alarms-8 ->
> List(0, 1), topic-1002-flink-base-rule-8 -> List(0, 1),
> topic-1002-sia-analysed-alarms-10 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
> IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
> Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
> List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
> 行 916: [2021-12-11 15:56:31,207] DEBUG [Controller id=2] Topics not in
> preferred replica for broker 0
> HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
> IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
> Notify_IES_Common_ServiceInstance-3 -> List(0, 1),
> topic-1002-flink-base-rule-2 -> List(0, 1), IES.tunnel.eventext.1002-4 ->
> List(0, 1), Notify_IES_Common_ServiceInstance-9 -> List(0, 1),
> SID_TroubeEvent-7 -> List(0, 1), IES.tunnel.config.1002-3 -> List(0, 1),
> ceae-1002-event-overload-1 -> List(0, 1), IES.tunnel.resource.1002-11 ->
> List(0, 2), cea-1002-event-nbi-10 -> List(0, 1),
> topic-sia-affected-services-6 -> List(0, 1), topic-1002-flink-config-2 ->
> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1), IES.tunnel.syncevent.1002-2
> -> List(0, 1), __consumer_offsets-9 -> List(0, 2, 1),
> topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
> List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
> ceae-1002-characteristic-instance-7 -> List(0, 1),
> topic-1002-flink-original-7 -> List(0, 1), topic-1002-sia-filtered-alarms-0
> -> List(0, 1), mateinfo.1002.nfsalarmtopic-6 -> List(0, 1),
> topic-1002-sia-analysed-alarms-4 -> List(0, 1),
> IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1), dispatch_alarm_topic-8 ->
> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
> topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
> -> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
> List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1),
> topic-1002-flink-original-1 -> List(0, 1), topic-sia-filtered-alarms-8 ->
> List(0, 1), topic-1002-flink-base-rule-8 -> List(0, 1),
> topic-1002-sia-analysed-alarms-10 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
> IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
> Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
> List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
> 行 925: [2021-12-11 16:01:31,212] DEBUG [Controller id=2] Topics not in
> preferred replica for broker 0
> HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
> IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
> Notify_IES_Common_ServiceInstance-3 -> List(0, 1),
> topic-1002-flink-base-rule-2 -> List(0, 1), IES.tunnel.eventext.1002-4 ->
> List(0, 1), Notify_IES_Common_ServiceInstance-9 -> List(0, 1),
> SID_TroubeEvent-7 -> List(0, 1), IES.tunnel.config.1002-3 -> List(0, 1),
> ceae-1002-event-overload-1 -> List(0, 1), IES.tunnel.resource.1002-11 ->
> List(0, 2), cea-1002-event-nbi-10 -> List(0, 1),
> topic-sia-affected-services-6 -> List(0, 1), topic-1002-flink-config-2 ->
> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1), IES.tunnel.syncevent.1002-2
> -> List(0, 1), __consumer_offsets-9 -> List(0, 2, 1),
> topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
> List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
> ceae-1002-characteristic-instance-7 -> List(0, 1),
> topic-1002-flink-original-7 -> List(0, 1), topic-1002-sia-filtered-alarms-0
> -> List(0, 1), mateinfo.1002.nfsalarmtopic-6 -> List(0, 1),
> topic-1002-sia-analysed-alarms-4 -> List(0, 1),
> IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1), dispatch_alarm_topic-8 ->
> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
> topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
> -> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
> List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1),
> topic-1002-flink-original-1 -> List(0, 1), topic-sia-filtered-alarms-8 ->
> List(0, 1), topic-1002-flink-base-rule-8 -> List(0, 1),
> topic-1002-sia-analysed-alarms-10 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
> IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
> Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
> List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
> 行 934: [2021-12-11 16:06:31,219] DEBUG [Controller id=2] Topics not in
> preferred replica for broker 0
> HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
> IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
> Notify_IES_Common_ServiceInstance-3 -> List(0, 1),
> topic-1002-flink-base-rule-2 -> List(0, 1), IES.tunnel.eventext.1002-4 ->
> List(0, 1), Notify_IES_Common_ServiceInstance-9 -> List(0, 1),
> SID_TroubeEvent-7 -> List(0, 1), IES.tunnel.config.1002-3 -> List(0, 1),
> ceae-1002-event-overload-1 -> List(0, 1), IES.tunnel.resource.1002-11 ->
> List(0, 2), cea-1002-event-nbi-10 -> List(0, 1),
> topic-sia-affected-services-6 -> List(0, 1), topic-1002-flink-config-2 ->
> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1), IES.tunnel.syncevent.1002-2
> -> List(0, 1), __consumer_offsets-9 -> List(0, 2, 1),
> topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
> List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
> ceae-1002-characteristic-instance-7 -> List(0, 1),
> topic-1002-flink-original-7 -> List(0, 1), topic-1002-sia-filtered-alarms-0
> -> List(0, 1), mateinfo.1002.nfsalarmtopic-6 -> List(0, 1),
> topic-1002-sia-analysed-alarms-4 -> List(0, 1),
> IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1), dispatch_alarm_topic-8 ->
> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
> topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
> -> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
> List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1),
> topic-1002-flink-original-1 -> List(0, 1), topic-sia-filtered-alarms-8 ->
> List(0, 1), topic-1002-flink-base-rule-8 -> List(0, 1),
> topic-1002-sia-analysed-alarms-10 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
> IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
> Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
> List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
> 行 943: [2021-12-11 16:11:31,227] DEBUG [Controller id=2] Topics not in
> preferred replica for broker 0
> HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
> IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
> Notify_IES_Common_ServiceInstance-3 -> List(0, 1),
> topic-1002-flink-base-rule-2 -> List(0, 1), IES.tunnel.eventext.1002-4 ->
> List(0, 1), Notify_IES_Common_ServiceInstance-9 -> List(0, 1),
> SID_TroubeEvent-7 -> List(0, 1), IES.tunnel.config.1002-3 -> List(0, 1),
> ceae-1002-event-overload-1 -> List(0, 1), IES.tunnel.resource.1002-11 ->
> List(0, 2), cea-1002-event-nbi-10 -> List(0, 1),
> topic-sia-affected-services-6 -> List(0, 1), topic-1002-flink-config-2 ->
> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1), IES.tunnel.syncevent.1002-2
> -> List(0, 1), __consumer_offsets-9 -> List(0, 2, 1),
> topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
> List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
> ceae-1002-characteristic-instance-7 -> List(0, 1),
> topic-1002-flink-original-7 -> List(0, 1), topic-1002-sia-filtered-alarms-0
> -> List(0, 1), mateinfo.1002.nfsalarmtopic-6 -> List(0, 1),
> topic-1002-sia-analysed-alarms-4 -> List(0, 1),
> IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1), dispatch_alarm_topic-8 ->
> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
> topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
> -> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
> List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1),
> topic-1002-flink-original-1 -> List(0, 1), topic-sia-filtered-alarms-8 ->
> List(0, 1), topic-1002-flink-base-rule-8 -> List(0, 1),
> topic-1002-sia-analysed-alarms-10 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
> IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
> Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
> List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
> 行 952: [2021-12-11 16:16:31,235] DEBUG [Controller id=2] Topics not in
> preferred replica for broker 0
> HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
> IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
> Notify_IES_Common_ServiceInstance-3 -> List(0, 1),
> topic-1002-flink-base-rule-2 -> List(0, 1), IES.tunnel.eventext.1002-4 ->
> List(0, 1), Notify_IES_Common_ServiceInstance-9 -> List(0, 1),
> SID_TroubeEvent-7 -> List(0, 1), IES.tunnel.config.1002-3 -> List(0, 1),
> ceae-1002-event-overload-1 -> List(0, 1), IES.tunnel.resource.1002-11 ->
> List(0, 2), cea-1002-event-nbi-10 -> List(0, 1),
> topic-sia-affected-services-6 -> List(0, 1), topic-1002-flink-config-2 ->
> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1), IES.tunnel.syncevent.1002-2
> -> List(0, 1), __consumer_offsets-9 -> List(0, 2, 1),
> topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
> List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
> ceae-1002-characteristic-instance-7 -> List(0, 1),
> topic-1002-flink-original-7 -> List(0, 1), topic-1002-sia-filtered-alarms-0
> -> List(0, 1), mateinfo.1002.nfsalarmtopic-6 -> List(0, 1),
> topic-1002-sia-analysed-alarms-4 -> List(0, 1),
> IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1), dispatch_alarm_topic-8 ->
> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
> topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
> -> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
> List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1),
> topic-1002-flink-original-1 -> List(0, 1), topic-sia-filtered-alarms-8 ->
> List(0, 1), topic-1002-flink-base-rule-8 -> List(0, 1),
> topic-1002-sia-analysed-alarms-10 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
> IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
> Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
> List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
> 行 961: [2021-12-11 16:21:31,240] DEBUG [Controller id=2] Topics not in
> preferred replica for broker 0
> HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
> IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
> Notify_IES_Common_ServiceInstance-3 -> List(0, 1),
> topic-1002-flink-base-rule-2 -> List(0, 1), IES.tunnel.eventext.1002-4 ->
> List(0, 1), Notify_IES_Common_ServiceInstance-9 -> List(0, 1),
> SID_TroubeEvent-7 -> List(0, 1), IES.tunnel.config.1002-3 -> List(0, 1),
> ceae-1002-event-overload-1 -> List(0, 1), IES.tunnel.resource.1002-11 ->
> List(0, 2), cea-1002-event-nbi-10 -> List(0, 1),
> topic-sia-affected-services-6 -> List(0, 1), topic-1002-flink-config-2 ->
> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1), IES.tunnel.syncevent.1002-2
> -> List(0, 1), __consumer_offsets-9 -> List(0, 2, 1),
> topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
> List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
> ceae-1002-characteristic-instance-7 -> List(0, 1),
> topic-1002-flink-original-7 -> List(0, 1), topic-1002-sia-filtered-alarms-0
> -> List(0, 1), mateinfo.1002.nfsalarmtopic-6 -> List(0, 1),
> topic-1002-sia-analysed-alarms-4 -> List(0, 1),
> IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1), dispatch_alarm_topic-8 ->
> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
> topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
> -> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
> List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1),
> topic-1002-flink-original-1 -> List(0, 1), topic-sia-filtered-alarms-8 ->
> List(0, 1), topic-1002-flink-base-rule-8 -> List(0, 1),
> topic-1002-sia-analysed-alarms-10 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
> IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
> Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
> List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
> 行 970: [2021-12-11 16:26:31,247] DEBUG [Controller id=2] Topics not in
> preferred replica for broker 0
> HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
> IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
> Notify_IES_Common_ServiceInstance-3 -> List(0, 1),
> topic-1002-flink-base-rule-2 -> List(0, 1), IES.tunnel.eventext.1002-4 ->
> List(0, 1), Notify_IES_Common_ServiceInstance-9 -> List(0, 1),
> SID_TroubeEvent-7 -> List(0, 1), IES.tunnel.config.1002-3 -> List(0, 1),
> ceae-1002-event-overload-1 -> List(0, 1), IES.tunnel.resource.1002-11 ->
> List(0, 2), cea-1002-event-nbi-10 -> List(0, 1),
> topic-sia-affected-services-6 -> List(0, 1), topic-1002-flink-config-2 ->
> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1), IES.tunnel.syncevent.1002-2
> -> List(0, 1), __consumer_offsets-9 -> List(0, 2, 1),
> topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
> List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
> ceae-1002-characteristic-instance-7 -> List(0, 1),
> topic-1002-flink-original-7 -> List(0, 1), topic-1002-sia-filtered-alarms-0
> -> List(0, 1), mateinfo.1002.nfsalarmtopic-6 -> List(0, 1),
> topic-1002-sia-analysed-alarms-4 -> List(0, 1),
> IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1), dispatch_alarm_topic-8 ->
> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
> topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
> -> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
> List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1),
> topic-1002-flink-original-1 -> List(0, 1), topic-sia-filtered-alarms-8 ->
> List(0, 1), topic-1002-flink-base-rule-8 -> List(0, 1),
> topic-1002-sia-analysed-alarms-10 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
> IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
> Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
> List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
> 行 979: [2021-12-11 16:31:31,252] DEBUG [Controller id=2] Topics not in
> preferred replica for broker 0
> HashMap(topic-datasource-access-NetcareLiteKPI-1002-2 -> List(0, 1),
> IES.tunnel.object.1002-4 -> List(0, 1), cea-1002-event-base-10 -> List(0, 1),
> Notify_IES_Common_ServiceInstance-3 -> List(0, 1),
> topic-1002-flink-base-rule-2 -> List(0, 1), IES.tunnel.eventext.1002-4 ->
> List(0, 1), Notify_IES_Common_ServiceInstance-9 -> List(0, 1),
> SID_TroubeEvent-7 -> List(0, 1), IES.tunnel.config.1002-3 -> List(0, 1),
> ceae-1002-event-overload-1 -> List(0, 1), IES.tunnel.resource.1002-11 ->
> List(0, 2), cea-1002-event-nbi-10 -> List(0, 1),
> topic-sia-affected-services-6 -> List(0, 1), topic-1002-flink-config-2 ->
> List(0, 1), IES.tunnel.dts.1002-2 -> List(0, 1), IES.tunnel.syncevent.1002-2
> -> List(0, 1), __consumer_offsets-9 -> List(0, 2, 1),
> topic-1002-sia-service-outer-10 -> List(0, 1), ceae-1002-event-base-6 ->
> List(0, 1), IES.tunnel.cooperationResource.1002-0 -> List(0, 1),
> ceae-1002-characteristic-instance-7 -> List(0, 1),
> topic-1002-flink-original-7 -> List(0, 1), topic-1002-sia-filtered-alarms-0
> -> List(0, 1), mateinfo.1002.nfsalarmtopic-6 -> List(0, 1),
> topic-1002-sia-analysed-alarms-4 -> List(0, 1),
> IES.tunnel.rmconsumerservice.1002-7 -> List(0, 1), dispatch_alarm_topic-8 ->
> List(0, 1), cea-1002-config-model-7 -> List(0, 1),
> topic-1002-sia-filtered-alarms-6 -> List(0, 1), topic-sia-affected-services-9
> -> List(0, 2), cea-1002-event-nbi-4 -> List(0, 1), IES.tunnel.alarm.1002-9 ->
> List(0, 1), IES.tunnel.config.1002-9 -> List(0, 1),
> topic-1002-flink-original-1 -> List(0, 1), topic-sia-filtered-alarms-8 ->
> List(0, 1), topic-1002-flink-base-rule-8 -> List(0, 1),
> topic-1002-sia-analysed-alarms-10 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-6 -> List(0, 1),
> IES.tunnel.cooperationResource.1002-6 -> List(0, 1),
> Notify_IES_Common_Customer-8 -> List(0, 1), IES.tunnel.resource.1002-2 ->
> List(0, 1), topic-1002-flink-reflow-alarm-11 -> List(0, 1),
> ceae-1002-flink-characteristic-instance-data-0 -> List(0, 1), IE ...
> 行 1801: [2021-12-11 16:33:05,074] DEBUG [Controller id=2] Updating ISRs
> for partitions: Set(topic-datasource-access-NetcareLiteKPI-1002-3,
> cea-1002-event-base-0, IES.tunnel.eventext.1002-6, IES.tunnel.alarm.1002-9,
> ceae-1002-event-base-10, cea-1002-config-model-7, IES.tunnel.motypeevent-7,
> IES.tunnel.syncevent.1002-10, ceae-1002-event-output-1,
> IES.tunnel.dts.1002-8, dispatch_alarm_topic-8,
> ceae-1002-flink-characteristic-instance-data-0, dispatch_alarm_topic-3,
> ceae-1002-event-output-5, IES.tunnel.syncevent.1002-2,
> ceae-1002-flink-suppression-message-9, Notify_IES_Common_Customer-8).
> (kafka.controller.KafkaController)
> 行 1812: [2021-12-11 16:33:05,118] DEBUG [Controller id=2] ISR for
> partition ceae-1002-flink-characteristic-instance-data-0 updated to [1,0] and
> zkVersion****{*}#{*}#***** (kafka.controller.KafkaController)
> 行 2068: [2021-12-11 16:38:02,885] INFO [Controller id=2] Partition
> ceae-1002-flink-characteristic-instance-data-0 completed preferred replica
> leader election. New leader is 0 (kafka.controller.KafkaController)
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
