{\rtf1\ansi\ansicpg1252\cocoartf2513
\cocoatextscaling0\cocoaplatform0{\fonttbl\f0\fmodern\fcharset0 Courier;}
{\colortbl;\red255\green255\blue255;\red38\green38\blue38;\red229\green235\blue239;}
{\*\expandedcolortbl;;\cssrgb\c20000\c20000\c20000;\cssrgb\c91765\c93725\c94902;}
\margl1440\margr1440\vieww28420\viewh17660\viewkind0
\deftab720
\pard\pardeftab720\partightenfactor0

\f0\fs24 \cf2 \cb3 \expnd0\expndtw0\kerning0
\outl0\strokewidth0 \strokec2 [2021-07-21 09:49:29,672] INFO Started initializing with configs: \{remote.log.metadata.topic.replication.factor=2, remote.log.metadata.topic.retention.ms=86400000, remote.log.metadata.consume.wait.ms=5000, remote.log.metadata.topic.num.partitions=3, remote.log.metadata.common.client.bootstrap.servers=localhost:38455,localhost:36317,localhost:44671, broker.id=0\} (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:303)\
[2021-07-21 09:49:29,718] INFO Successfully initialized with rlmmConfig: TopicBasedRemoteLogMetadataManagerConfig\{clientIdPrefix='__remote_log_metadata_client_0', metadataTopicPartitionsCount=3, consumeWaitMs=5000, metadataTopicRetentionMs=86400000, metadataTopicReplicationFactor=2, initializationRetryMaxTimeoutMs=120000, initializationRetryIntervalMs=5000, consumerProps=\{key.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer, value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer, enable.auto.commit=false, bootstrap.servers=localhost:38455,localhost:36317,localhost:44671, exclude.internal.topics=false, auto.offset.reset=earliest, client.id=__remote_log_metadata_client_0_consumer\}, producerProps=\{bootstrap.servers=localhost:38455,localhost:36317,localhost:44671, value.serializer=org.apache.kafka.common.serialization.ByteArraySerializer, max.in.flight.requests.per.connection=1, key.serializer=org.apache.kafka.common.serialization.ByteArraySerializer, client.id=__remote_log_metadata_client_0_producer, acks=all\}\} (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:308)\
[2021-07-21 09:49:29,733] INFO Initializing the resources. (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:321)\
[2021-07-21 09:49:31,116] INFO Initialized resources successfully. (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:377)\
[2021-07-21 09:49:31,116] INFO Started Consumer task thread. (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:102)\
[2021-07-21 09:49:31,132] INFO Received leadership notifications with leader partitions [] and follower partitions [] (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:248)\
[2021-07-21 09:49:31,133] INFO Updating assignments for addedPartitions: [] and removedPartition: [] (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:196)\
[2021-07-21 09:49:33,893] INFO Received leadership notifications with leader partitions [TopicIdPartition\{topicId=2B9rDu44TE6c8pLG8A0RAg, topicPartition=new-leader-0\}] and follower partitions [TopicIdPartition\{topicId=9geHynruSY-XXYGNMwYBvg, topicPartition=new-follower-0\}] (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:248)\
[2021-07-21 09:49:33,894] INFO Updating assignments for addedPartitions: [TopicIdPartition\{topicId=2B9rDu44TE6c8pLG8A0RAg, topicPartition=new-leader-0\}, TopicIdPartition\{topicId=9geHynruSY-XXYGNMwYBvg, topicPartition=new-follower-0\}] and removedPartition: [] (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:196)\
[2021-07-21 09:49:33,896] INFO Reassigning partitions to consumer task [[__remote_log_metadata-2, __remote_log_metadata-0]] (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:182)\
[2021-07-21 09:49:33,903] INFO Polling consumer to receive remote log metadata topic records (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:107)\
[2021-07-21 09:49:33,995] INFO Polling consumer to receive remote log metadata topic records (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:107)\
[2021-07-21 09:49:33,998] INFO Polling consumer to receive remote log metadata topic records (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:107)\
[2021-07-21 09:49:34,005] INFO Closing the resources. (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:463)\
[2021-07-21 09:49:34,013] ERROR Error occurred in consumer task, close:[true] (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:116)\
org.apache.kafka.common.errors.WakeupException\
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.maybeTriggerWakeup(ConsumerNetworkClient.java:514)\
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:278)\
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236)\
	at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1297)\
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1238)\
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1211)\
	at org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask.run(ConsumerTask.java:109)\
	at java.base/java.lang.Thread.run(Thread.java:834)\
[2021-07-21 09:49:34,018] INFO Closing the consumer instance (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:124)\
[2021-07-21 09:49:34,025] INFO Exiting from consumer task thread (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:119)\
[2021-07-21 09:49:34,025] INFO Clearing the entries from the store. (org.apache.kafka.server.log.remote.metadata.storage.RemotePartitionMetadataStore:136)\
[2021-07-21 09:49:34,026] INFO Closed the resources. (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:480)\
[2021-07-21 09:50:41,942] INFO Started initializing with configs: \{remote.log.metadata.topic.replication.factor=2, remote.log.metadata.topic.retention.ms=86400000, remote.log.metadata.consume.wait.ms=5000, remote.log.metadata.topic.num.partitions=3, remote.log.metadata.common.client.bootstrap.servers=localhost:36737,localhost:37353,localhost:37579, broker.id=0\} (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:303)\
[2021-07-21 09:50:41,954] INFO Successfully initialized with rlmmConfig: TopicBasedRemoteLogMetadataManagerConfig\{clientIdPrefix='__remote_log_metadata_client_0', metadataTopicPartitionsCount=3, consumeWaitMs=5000, metadataTopicRetentionMs=86400000, metadataTopicReplicationFactor=2, initializationRetryMaxTimeoutMs=120000, initializationRetryIntervalMs=5000, consumerProps=\{key.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer, value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer, enable.auto.commit=false, bootstrap.servers=localhost:36737,localhost:37353,localhost:37579, exclude.internal.topics=false, auto.offset.reset=earliest, client.id=__remote_log_metadata_client_0_consumer\}, producerProps=\{bootstrap.servers=localhost:36737,localhost:37353,localhost:37579, value.serializer=org.apache.kafka.common.serialization.ByteArraySerializer, max.in.flight.requests.per.connection=1, key.serializer=org.apache.kafka.common.serialization.ByteArraySerializer, client.id=__remote_log_metadata_client_0_producer, acks=all\}\} (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:308)\
[2021-07-21 09:50:41,959] INFO Initializing the resources. (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:321)\
[2021-07-21 09:50:44,369] INFO Initialized resources successfully. (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:377)\
[2021-07-21 09:50:44,369] INFO Started Consumer task thread. (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:102)\
[2021-07-21 09:50:44,437] INFO Received leadership notifications with leader partitions [] and follower partitions [] (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:248)\
[2021-07-21 09:50:44,439] INFO Updating assignments for addedPartitions: [] and removedPartition: [] (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:196)\
[2021-07-21 09:50:44,993] INFO Received leadership notifications with leader partitions [TopicIdPartition\{topicId=_TqebuhCRhqOnG6VYEwgTg, topicPartition=new-leader-0\}] and follower partitions [TopicIdPartition\{topicId=veTO4kC0TfiLAkofAkCcAg, topicPartition=new-follower-0\}] (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:248)\
[2021-07-21 09:50:44,994] INFO Updating assignments for addedPartitions: [TopicIdPartition\{topicId=veTO4kC0TfiLAkofAkCcAg, topicPartition=new-follower-0\}, TopicIdPartition\{topicId=_TqebuhCRhqOnG6VYEwgTg, topicPartition=new-leader-0\}] and removedPartition: [] (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:196)\
[2021-07-21 09:50:44,995] INFO Reassigning partitions to consumer task [[__remote_log_metadata-1]] (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:182)\
[2021-07-21 09:50:45,001] INFO Polling consumer to receive remote log metadata topic records (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:107)\
[2021-07-21 09:50:45,101] INFO Polling consumer to receive remote log metadata topic records (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:107)\
[2021-07-21 09:50:45,201] INFO Closing the resources. (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:463)\
[2021-07-21 09:50:45,202] INFO Polling consumer to receive remote log metadata topic records (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:107)\
[2021-07-21 09:50:45,216] ERROR Error occurred in consumer task, close:[true] (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:116)\
org.apache.kafka.common.errors.WakeupException\
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.maybeTriggerWakeup(ConsumerNetworkClient.java:514)\
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:278)\
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236)\
	at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1297)\
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1238)\
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1211)\
	at org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask.run(ConsumerTask.java:109)\
	at java.base/java.lang.Thread.run(Thread.java:834)\
[2021-07-21 09:50:45,228] INFO Closing the consumer instance (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:124)\
[2021-07-21 09:50:45,236] INFO Exiting from consumer task thread (org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:119)\
[2021-07-21 09:50:45,236] INFO Clearing the entries from the store. (org.apache.kafka.server.log.remote.metadata.storage.RemotePartitionMetadataStore:136)\
[2021-07-21 09:50:45,237] INFO Closed the resources. (org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager:480)\
}