[
https://issues.apache.org/jira/browse/KAFKA-13564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17464929#comment-17464929
]
ZhenChun Pan edited comment on KAFKA-13564 at 12/24/21, 8:50 AM:
-----------------------------------------------------------------
[~showuon] I add some log imformation about the topic partition
ceae-1002-flink-characteristic-instance-data-0 in the description, include the
server.log and state-change.log of broker0, and controller.log in broker2.
was (Author: JIRAUSER280457):
I add some log imformation about the topic partition
ceae-1002-flink-characteristic-instance-data-0 in the description, include the
server.log and state-change.log of broker0, and controller.log in broker2.
> 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:
> Search"ceae-1002-flink-characteristic-instance-data-0"
> \20211211\broker0\server.log
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> .......................
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Search "ceae-1002-flink-characteristic-instance-data-0"
> 20211211\broker0\state-change.log
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Line 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)
> Search "ceae-1002-flink-characteristic-instance-data-0"
> 20211211\broker2\controller.log
> Line 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 ...
> Line 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 ...
> Line 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 ...
> Line 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 ...
> Line 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 ...
> Line 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 ...
> Line 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 ...
> Line 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 ...
> Line 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 ...
> Line 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 ...
> Line 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 ...
> Line 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)
> Line 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)
> Line 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)
