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)