Updated Producer with requirements

4 files changed, 1363 insertions, 4 deletions

diff --git a/kafka/logs/controller.log.2021-12-23-18 b/kafka/logs/controller.log.2021-12-23-18
new file mode 100644
index 0000000..7661959
--- /dev/null
+++ b/kafka/logs/controller.log.2021-12-23-18
@@ -0,0 +1,69 @@
+[2021-12-23 18:21:57,883] DEBUG preRegister called. Server=com.sun.jmx.mbeanserver.JmxMBeanServer@bd8db5a, name=log4j:logger=kafka.controller (kafka.controller)
+[2021-12-23 18:22:46,541] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread)
+[2021-12-23 18:22:46,566] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 4 and epoch zk version is now 4 (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,567] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,569] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,570] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,571] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,576] INFO [Controller id=0] Initialized broker epochs cache: HashMap(0 -> 436) (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,586] DEBUG [Controller id=0] Register BrokerModifications handler for Set(0) (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,614] DEBUG [Channel manager on controller 0]: Controller 0 trying to connect to broker 0 (kafka.controller.ControllerChannelManager)
+[2021-12-23 18:22:46,618] INFO [RequestSendThread controllerId=0] Starting (kafka.controller.RequestSendThread)
+[2021-12-23 18:22:46,618] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,619] INFO [Controller id=0] Currently shutting brokers in the cluster: HashSet() (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,619] INFO [Controller id=0] Current list of topics in the cluster: HashSet(quickstart-events, _confluent_balancer_api_state, _confluent_balancer_broker_samples, _confluent-command, _confluent_balancer_partition_samples, _confluent-telemetry-metrics, __consumer_offsets) (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,619] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,623] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,623] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,623] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,624] INFO [Topic Deletion Manager 0] Initializing manager with initial deletions: Set(), initial ineligible deletions: HashSet() (kafka.controller.TopicDeletionManager)
+[2021-12-23 18:22:46,625] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,632] INFO [ReplicaStateMachine controllerId=0] Initializing replica state (kafka.controller.ZkReplicaStateMachine)
+[2021-12-23 18:22:46,636] INFO [ReplicaStateMachine controllerId=0] Triggering online replica state changes (kafka.controller.ZkReplicaStateMachine)
+[2021-12-23 18:22:46,637] INFO [RequestSendThread controllerId=0] Controller 0 connected to 10.84.99.135:9092 (id: 0 rack: null) for sending state change requests (kafka.controller.RequestSendThread)
+[2021-12-23 18:22:46,657] INFO [ReplicaStateMachine controllerId=0] Triggering offline replica state changes (kafka.controller.ZkReplicaStateMachine)
+[2021-12-23 18:22:46,657] DEBUG [ReplicaStateMachine controllerId=0] Started replica state machine with initial state -> HashMap([Topic=_confluent_balancer_api_state,Partition=0,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=21,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=27,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=29,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=28,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=49,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=47,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=8,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=0,Replica=0] -> OnlineReplica, [Topic=_confluent-telemetry-metrics,Partition=7,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=8,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=31,Replica=0] -> OnlineReplica, [Topic=_confluent-telemetry-metrics,Partition=6,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=15,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=2,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=14,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=36,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=9,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=18,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=42,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=30,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=22,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=12,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=45,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=9,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=32,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=9,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=7,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=5,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=39,Replica=0] -> OnlineReplica, [Topic=_confluent-telemetry-metrics,Partition=8,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=38,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=18,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=23,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=20,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=2,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=23,Replica=0] -> OnlineReplica, [Topic=_confluent-telemetry-metrics,Partition=11,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=37,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=10,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=30,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=21,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=27,Replica=0] -> OnlineReplica, [Topic=_confluent-telemetry-metrics,Partition=0,Replica=0] -> OnlineReplica, [Topic=_confluent-telemetry-metrics,Partition=4,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=15,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=24,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=31,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=28,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=1,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=26,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=2,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=33,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=15,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=16,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=13,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=23,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=12,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=13,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=8,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=35,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=11,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=14,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=40,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=27,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=4,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=3,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=18,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=44,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=17,Replica=0] -> OnlineReplica, [Topic=_confluent-telemetry-metrics,Partition=3,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=4,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=10,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=20,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=34,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=25,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=6,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=24,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=5,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=28,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=3,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=11,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=25,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=16,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=12,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=30,Replica=0] -> OnlineReplica, [Topic=_confluent-command,Partition=0,Replica=0] -> OnlineReplica, [Topic=_confluent-telemetry-metrics,Partition=5,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=0,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=25,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=7,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=10,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=17,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=26,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=26,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=19,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=17,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=41,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=29,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=11,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=48,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=29,Replica=0] -> OnlineReplica, [Topic=_confluent-telemetry-metrics,Partition=2,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=46,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=1,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=16,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=24,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=5,Replica=0] -> OnlineReplica, [Topic=quickstart-events,Partition=0,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=6,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=4,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=6,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=7,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=43,Replica=0] -> OnlineReplica, [Topic=_confluent-telemetry-metrics,Partition=9,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=0,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=1,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_broker_samples,Partition=19,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=19,Replica=0] -> OnlineReplica, [Topic=_confluent-telemetry-metrics,Partition=1,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=3,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=20,Replica=0] -> OnlineReplica, [Topic=_confluent-telemetry-metrics,Partition=10,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=13,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=31,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=22,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=22,Replica=0] -> OnlineReplica, [Topic=__consumer_offsets,Partition=21,Replica=0] -> OnlineReplica, [Topic=_confluent_balancer_partition_samples,Partition=14,Replica=0] -> OnlineReplica) (kafka.controller.ZkReplicaStateMachine)
+[2021-12-23 18:22:46,657] INFO [PartitionStateMachine controllerId=0] Initializing partition state (kafka.controller.ZkPartitionStateMachine)
+[2021-12-23 18:22:46,662] INFO [PartitionStateMachine controllerId=0] Triggering online partition state changes (kafka.controller.ZkPartitionStateMachine)
+[2021-12-23 18:22:46,664] DEBUG [PartitionStateMachine controllerId=0] Started partition state machine with initial state -> HashMap(__consumer_offsets-13 -> OnlinePartition, __consumer_offsets-46 -> OnlinePartition, _confluent_balancer_broker_samples-29 -> OnlinePartition, _confluent-telemetry-metrics-10 -> OnlinePartition, _confluent_balancer_partition_samples-11 -> OnlinePartition, __consumer_offsets-21 -> OnlinePartition, _confluent_balancer_broker_samples-21 -> OnlinePartition, _confluent_balancer_partition_samples-3 -> OnlinePartition, __consumer_offsets-30 -> OnlinePartition, _confluent_balancer_partition_samples-28 -> OnlinePartition, _confluent_balancer_broker_samples-12 -> OnlinePartition, __consumer_offsets-5 -> OnlinePartition, __consumer_offsets-38 -> OnlinePartition, _confluent-telemetry-metrics-1 -> OnlinePartition, _confluent_balancer_partition_samples-20 -> OnlinePartition, _confluent_balancer_broker_samples-4 -> OnlinePartition, _confluent_balancer_broker_samples-22 -> OnlinePartition, __consumer_offsets-45 -> OnlinePartition, __consumer_offsets-12 -> OnlinePartition, _confluent-telemetry-metrics-9 -> OnlinePartition, _confluent_balancer_partition_samples-12 -> OnlinePartition, _confluent_balancer_partition_samples-29 -> OnlinePartition, _confluent_balancer_broker_samples-14 -> OnlinePartition, __consumer_offsets-20 -> OnlinePartition, _confluent_balancer_partition_samples-4 -> OnlinePartition, _confluent_balancer_partition_samples-21 -> OnlinePartition, __consumer_offsets-29 -> OnlinePartition, _confluent_balancer_broker_samples-13 -> OnlinePartition, _confluent_balancer_partition_samples-13 -> OnlinePartition, _confluent_balancer_broker_samples-30 -> OnlinePartition, __consumer_offsets-37 -> OnlinePartition, _confluent-telemetry-metrics-0 -> OnlinePartition, __consumer_offsets-4 -> OnlinePartition, _confluent_balancer_broker_samples-5 -> OnlinePartition, __consumer_offsets-15 -> OnlinePartition, _confluent_balancer_broker_samples-23 -> OnlinePartition, _confluent_balancer_partition_samples-5 -> OnlinePartition, __consumer_offsets-48 -> OnlinePartition, _confluent-telemetry-metrics-8 -> OnlinePartition, _confluent_balancer_partition_samples-30 -> OnlinePartition, __consumer_offsets-23 -> OnlinePartition, _confluent_balancer_broker_samples-15 -> OnlinePartition, _confluent_balancer_partition_samples-22 -> OnlinePartition, __consumer_offsets-32 -> OnlinePartition, _confluent_balancer_broker_samples-6 -> OnlinePartition, _confluent_balancer_partition_samples-14 -> OnlinePartition, __consumer_offsets-7 -> OnlinePartition, _confluent_balancer_broker_samples-31 -> OnlinePartition, __consumer_offsets-40 -> OnlinePartition, _confluent_balancer_partition_samples-6 -> OnlinePartition, __consumer_offsets-47 -> OnlinePartition, quickstart-events-0 -> OnlinePartition, __consumer_offsets-14 -> OnlinePartition, _confluent_balancer_broker_samples-24 -> OnlinePartition, _confluent-telemetry-metrics-7 -> OnlinePartition, _confluent_balancer_partition_samples-31 -> OnlinePartition, __consumer_offsets-22 -> OnlinePartition, _confluent_balancer_broker_samples-16 -> OnlinePartition, __consumer_offsets-31 -> OnlinePartition, _confluent_balancer_broker_samples-7 -> OnlinePartition, _confluent_balancer_partition_samples-23 -> OnlinePartition, __consumer_offsets-39 -> OnlinePartition, _confluent_balancer_partition_samples-15 -> OnlinePartition, __consumer_offsets-6 -> OnlinePartition, _confluent_balancer_broker_samples-25 -> OnlinePartition, _confluent-telemetry-metrics-6 -> OnlinePartition, _confluent_balancer_partition_samples-7 -> OnlinePartition, __consumer_offsets-9 -> OnlinePartition, __consumer_offsets-42 -> OnlinePartition, _confluent_balancer_broker_samples-17 -> OnlinePartition, __consumer_offsets-17 -> OnlinePartition, _confluent_balancer_partition_samples-24 -> OnlinePartition, _confluent_balancer_broker_samples-8 -> OnlinePartition, _confluent_balancer_api_state-0 -> OnlinePartition, __consumer_offsets-26 -> OnlinePartition, _confluent_balancer_partition_samples-16 -> OnlinePartition, _confluent_balancer_broker_samples-0 -> OnlinePartition, __consumer_offsets-1 -> OnlinePartition, __consumer_offsets-34 -> OnlinePartition, __consumer_offsets-16 -> OnlinePartition, _confluent-telemetry-metrics-5 -> OnlinePartition, _confluent_balancer_partition_samples-8 -> OnlinePartition, _confluent_balancer_broker_samples-26 -> OnlinePartition, __consumer_offsets-41 -> OnlinePartition, __consumer_offsets-24 -> OnlinePartition, _confluent_balancer_partition_samples-0 -> OnlinePartition, _confluent_balancer_broker_samples-18 -> OnlinePartition, __consumer_offsets-49 -> OnlinePartition, __consumer_offsets-0 -> OnlinePartition, _confluent_balancer_broker_samples-9 -> OnlinePartition, _confluent_balancer_partition_samples-25 -> OnlinePartition, __consumer_offsets-25 -> OnlinePartition, __consumer_offsets-8 -> OnlinePartition, _confluent_balancer_broker_samples-1 -> OnlinePartition, _confluent_balancer_partition_samples-17 -> OnlinePartition, __consumer_offsets-33 -> OnlinePartition, _confluent-telemetry-metrics-4 -> OnlinePartition, __consumer_offsets-11 -> OnlinePartition, _confluent_balancer_broker_samples-27 -> OnlinePartition, _confluent_balancer_partition_samples-9 -> OnlinePartition, __consumer_offsets-44 -> OnlinePartition, __consumer_offsets-19 -> OnlinePartition, _confluent_balancer_broker_samples-19 -> OnlinePartition, _confluent_balancer_partition_samples-1 -> OnlinePartition, _confluent_balancer_partition_samples-26 -> OnlinePartition, __consumer_offsets-28 -> OnlinePartition, _confluent_balancer_broker_samples-10 -> OnlinePartition, _confluent_balancer_partition_samples-18 -> OnlinePartition, __consumer_offsets-3 -> OnlinePartition, __consumer_offsets-36 -> OnlinePartition, _confluent_balancer_broker_samples-2 -> OnlinePartition, _confluent-telemetry-metrics-3 -> OnlinePartition, _confluent_balancer_partition_samples-10 -> OnlinePartition, __consumer_offsets-43 -> OnlinePartition, __consumer_offsets-10 -> OnlinePartition, _confluent_balancer_broker_samples-28 -> OnlinePartition, _confluent-telemetry-metrics-11 -> OnlinePartition, _confluent-command-0 -> OnlinePartition, _confluent_balancer_partition_samples-2 -> OnlinePartition, __consumer_offsets-18 -> OnlinePartition, _confluent_balancer_broker_samples-20 -> OnlinePartition, __consumer_offsets-27 -> OnlinePartition, _confluent_balancer_broker_samples-11 -> OnlinePartition, _confluent_balancer_partition_samples-27 -> OnlinePartition, __consumer_offsets-35 -> OnlinePartition, _confluent_balancer_broker_samples-3 -> OnlinePartition, _confluent-telemetry-metrics-2 -> OnlinePartition, _confluent_balancer_partition_samples-19 -> OnlinePartition, __consumer_offsets-2 -> OnlinePartition) (kafka.controller.ZkPartitionStateMachine)
+[2021-12-23 18:22:46,680] INFO [Controller id=0] Ready to serve as the new controller with epoch 4 (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,682] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,682] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,682] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,682] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,683] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController)
+[2021-12-23 18:22:46,722] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController)
+[2021-12-23 18:22:51,728] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
+[2021-12-23 18:22:51,729] TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
+[2021-12-23 18:22:51,735] DEBUG [Controller id=0] Topics not in preferred replica for broker 0 HashMap() (kafka.controller.KafkaController)
+[2021-12-23 18:22:51,737] TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController)
+[2021-12-23 18:23:26,446] INFO [Controller id=0] New topics: [HashSet(twitterdata)], deleted topics: [HashSet()], new partition replica assignment [Set(TopicIdReplicaAssignment(twitterdata,Some(Cj0oC1w_Shi9rRstWmQGVQ),Map(twitterdata-0 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), twitterdata-1 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=))))] (kafka.controller.KafkaController)
+[2021-12-23 18:23:26,447] INFO [Controller id=0] New partition creation callback for twitterdata-0,twitterdata-1 (kafka.controller.KafkaController)
+[2021-12-23 18:27:51,731] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
+[2021-12-23 18:27:51,733] TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
+[2021-12-23 18:27:51,738] DEBUG [Controller id=0] Topics not in preferred replica for broker 0 HashMap() (kafka.controller.KafkaController)
+[2021-12-23 18:27:51,738] TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController)
+[2021-12-23 18:32:51,728] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
+[2021-12-23 18:32:51,729] TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
+[2021-12-23 18:32:51,757] DEBUG [Controller id=0] Topics not in preferred replica for broker 0 HashMap() (kafka.controller.KafkaController)
+[2021-12-23 18:32:51,757] TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController)
+[2021-12-23 18:37:51,747] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
+[2021-12-23 18:37:51,748] TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
+[2021-12-23 18:37:51,751] DEBUG [Controller id=0] Topics not in preferred replica for broker 0 HashMap() (kafka.controller.KafkaController)
+[2021-12-23 18:37:51,751] TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController)
+[2021-12-23 18:42:51,745] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
+[2021-12-23 18:42:51,746] TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
+[2021-12-23 18:42:51,748] DEBUG [Controller id=0] Topics not in preferred replica for broker 0 HashMap() (kafka.controller.KafkaController)
+[2021-12-23 18:42:51,748] TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController)
+[2021-12-23 18:47:51,741] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
+[2021-12-23 18:47:51,742] TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
+[2021-12-23 18:47:51,743] DEBUG [Controller id=0] Topics not in preferred replica for broker 0 HashMap() (kafka.controller.KafkaController)
+[2021-12-23 18:47:51,743] TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController)
+[2021-12-23 18:52:51,738] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
+[2021-12-23 18:52:51,739] TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
+[2021-12-23 18:52:51,742] DEBUG [Controller id=0] Topics not in preferred replica for broker 0 HashMap() (kafka.controller.KafkaController)
+[2021-12-23 18:52:51,743] TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController)
+[2021-12-23 18:57:51,734] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
+[2021-12-23 18:57:51,735] TRACE [Controller id=0] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
+[2021-12-23 18:57:51,737] DEBUG [Controller id=0] Topics not in preferred replica for broker 0 HashMap() (kafka.controller.KafkaController)
+[2021-12-23 18:57:51,738] TRACE [Controller id=0] Leader imbalance ratio for broker 0 is 0.0 (kafka.controller.KafkaController)
diff --git a/kafka/logs/server.log.2021-12-23-18 b/kafka/logs/server.log.2021-12-23-18
new file mode 100644
index 0000000..75cc3c1
--- /dev/null
+++ b/kafka/logs/server.log.2021-12-23-18
@@ -0,0 +1,1286 @@
+[2021-12-23 18:21:57,873] INFO Reading configuration from: config/zookeeper.properties (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
+[2021-12-23 18:21:57,874] WARN config/zookeeper.properties is relative. Prepend ./ to indicate that you're sure! (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
+[2021-12-23 18:21:57,876] INFO clientPortAddress is 0.0.0.0:2181 (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
+[2021-12-23 18:21:57,876] INFO secureClientPort is not set (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
+[2021-12-23 18:21:57,876] INFO observerMasterPort is not set (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
+[2021-12-23 18:21:57,876] INFO metricsProvider.className is org.apache.zookeeper.metrics.impl.DefaultMetricsProvider (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
+[2021-12-23 18:21:57,877] INFO autopurge.snapRetainCount set to 3 (org.apache.zookeeper.server.DatadirCleanupManager)
+[2021-12-23 18:21:57,877] INFO autopurge.purgeInterval set to 0 (org.apache.zookeeper.server.DatadirCleanupManager)
+[2021-12-23 18:21:57,877] INFO Purge task is not scheduled. (org.apache.zookeeper.server.DatadirCleanupManager)
+[2021-12-23 18:21:57,877] WARN Either no config or no quorum defined in config, running in standalone mode (org.apache.zookeeper.server.quorum.QuorumPeerMain)
+[2021-12-23 18:21:57,879] INFO Log4j 1.2 jmx support found and enabled. (org.apache.zookeeper.jmx.ManagedUtil)
+[2021-12-23 18:21:57,884] INFO Reading configuration from: config/zookeeper.properties (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
+[2021-12-23 18:21:57,884] WARN config/zookeeper.properties is relative. Prepend ./ to indicate that you're sure! (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
+[2021-12-23 18:21:57,885] INFO clientPortAddress is 0.0.0.0:2181 (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
+[2021-12-23 18:21:57,885] INFO secureClientPort is not set (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
+[2021-12-23 18:21:57,885] INFO observerMasterPort is not set (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
+[2021-12-23 18:21:57,885] INFO metricsProvider.className is org.apache.zookeeper.metrics.impl.DefaultMetricsProvider (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
+[2021-12-23 18:21:57,885] INFO Starting server (org.apache.zookeeper.server.ZooKeeperServerMain)
+[2021-12-23 18:21:57,891] INFO ServerMetrics initialized with provider org.apache.zookeeper.metrics.impl.DefaultMetricsProvider@68c72235 (org.apache.zookeeper.server.ServerMetrics)
+[2021-12-23 18:21:57,893] INFO zookeeper.snapshot.trust.empty : false (org.apache.zookeeper.server.persistence.FileTxnSnapLog)
+[2021-12-23 18:21:57,898] INFO  (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,898] INFO   ______                  _                                           (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,898] INFO  |___  /                 | |                                          (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,898] INFO     / /    ___     ___   | | __   ___    ___   _ __     ___   _ __    (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,898] INFO    / /    / _ \   / _ \  | |/ /  / _ \  / _ \ | '_ \   / _ \ | '__| (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,898] INFO   / /__  | (_) | | (_) | |   <  |  __/ |  __/ | |_) | |  __/ | |     (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,898] INFO  /_____|  \___/   \___/  |_|\_\  \___|  \___| | .__/   \___| |_| (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,898] INFO                                               | |                      (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,898] INFO                                               |_|                      (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,898] INFO  (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,899] INFO Server environment:zookeeper.version=3.6.3--6401e4ad2087061bc6b9f80dec2d69f2e3c8660a, built on 04/08/2021 16:35 GMT (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,899] INFO Server environment:host.name=10.84.99.135 (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,899] INFO Server environment:java.version=17.0.1 (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,899] INFO Server environment:java.vendor=Eclipse Adoptium (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,899] INFO Server environment:java.home=/Library/Java/JavaVirtualMachines/temurin-17.jdk/Contents/Home (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,899] INFO Server environment:java.class.path=/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/activation-1.1.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/aopalliance-repackaged-2.6.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/argparse4j-0.7.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/audience-annotations-0.5.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/commons-cli-1.4.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/commons-lang3-3.8.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-api-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-basic-auth-extension-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-file-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-json-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-mirror-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-mirror-client-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-runtime-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-transforms-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/hk2-api-2.6.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/hk2-locator-2.6.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/hk2-utils-2.6.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-annotations-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-core-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-databind-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-dataformat-csv-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-datatype-jdk8-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-jaxrs-base-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-jaxrs-json-provider-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-module-jaxb-annotations-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-module-scala_2.13-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jakarta.activation-api-1.2.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jakarta.annotation-api-1.3.5.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jakarta.inject-2.6.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jakarta.validation-api-2.0.2.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jakarta.ws.rs-api-2.1.6.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jakarta.xml.bind-api-2.3.2.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/javassist-3.27.0-GA.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/javax.servlet-api-3.1.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/javax.ws.rs-api-2.1.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jaxb-api-2.3.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jersey-client-2.34.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jersey-common-2.34.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jersey-container-servlet-2.34.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jersey-container-servlet-core-2.34.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jersey-hk2-2.34.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jersey-server-2.34.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-client-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-continuation-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-http-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-io-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-security-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-server-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-servlet-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-servlets-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-util-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-util-ajax-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jline-3.12.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jopt-simple-5.0.4.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-clients-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-log4j-appender-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-metadata-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-raft-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-server-common-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-shell-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-storage-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-storage-api-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-streams-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-streams-examples-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-streams-scala_2.13-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-streams-test-utils-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-tools-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka_2.13-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/log4j-1.2.17.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/lz4-java-1.7.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/maven-artifact-3.8.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/metrics-core-2.2.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/metrics-core-4.1.12.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-buffer-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-codec-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-common-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-handler-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-resolver-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-transport-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-transport-native-epoll-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-transport-native-unix-common-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/osgi-resource-locator-1.0.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/paranamer-2.8.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/plexus-utils-3.2.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/reflections-0.9.12.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/rocksdbjni-6.19.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/scala-collection-compat_2.13-2.4.4.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/scala-java8-compat_2.13-1.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/scala-library-2.13.6.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/scala-logging_2.13-3.9.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/scala-reflect-2.13.6.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/slf4j-api-1.7.30.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/slf4j-log4j12-1.7.30.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/snappy-java-1.1.8.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/trogdor-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/zookeeper-3.6.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/zookeeper-jute-3.6.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/zstd-jni-1.5.0-2.jar (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO Server environment:java.library.path=/Users/lucifer/Library/Java/Extensions:/Library/Java/Extensions:/Network/Library/Java/Extensions:/System/Library/Java/Extensions:/usr/lib/java:. (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO Server environment:java.io.tmpdir=/var/folders/zz/zyxvpxvq6csfxvn_n0000000000000/T/ (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO Server environment:java.compiler=<NA> (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO Server environment:os.name=Mac OS X (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO Server environment:os.arch=aarch64 (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO Server environment:os.version=12.1 (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO Server environment:user.name=root (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO Server environment:user.home=/var/root (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO Server environment:user.dir=/Users/lucifer/Documents/projects/KafkaPySpark/kafka (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO Server environment:os.memory.free=495MB (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO Server environment:os.memory.max=512MB (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO Server environment:os.memory.total=512MB (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO zookeeper.enableEagerACLCheck = false (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO zookeeper.digest.enabled = true (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO zookeeper.closeSessionTxn.enabled = true (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO zookeeper.flushDelay=0 (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO zookeeper.maxWriteQueuePollTime=0 (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO zookeeper.maxBatchSize=1000 (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,900] INFO zookeeper.intBufferStartingSizeBytes = 1024 (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,901] INFO Weighed connection throttling is disabled (org.apache.zookeeper.server.BlueThrottle)
+[2021-12-23 18:21:57,901] INFO minSessionTimeout set to 6000 (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,901] INFO maxSessionTimeout set to 60000 (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,902] INFO Response cache size is initialized with value 400. (org.apache.zookeeper.server.ResponseCache)
+[2021-12-23 18:21:57,902] INFO Response cache size is initialized with value 400. (org.apache.zookeeper.server.ResponseCache)
+[2021-12-23 18:21:57,902] INFO zookeeper.pathStats.slotCapacity = 60 (org.apache.zookeeper.server.util.RequestPathMetricsCollector)
+[2021-12-23 18:21:57,902] INFO zookeeper.pathStats.slotDuration = 15 (org.apache.zookeeper.server.util.RequestPathMetricsCollector)
+[2021-12-23 18:21:57,903] INFO zookeeper.pathStats.maxDepth = 6 (org.apache.zookeeper.server.util.RequestPathMetricsCollector)
+[2021-12-23 18:21:57,903] INFO zookeeper.pathStats.initialDelay = 5 (org.apache.zookeeper.server.util.RequestPathMetricsCollector)
+[2021-12-23 18:21:57,903] INFO zookeeper.pathStats.delay = 5 (org.apache.zookeeper.server.util.RequestPathMetricsCollector)
+[2021-12-23 18:21:57,903] INFO zookeeper.pathStats.enabled = false (org.apache.zookeeper.server.util.RequestPathMetricsCollector)
+[2021-12-23 18:21:57,904] INFO The max bytes for all large requests are set to 104857600 (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,904] INFO The large request threshold is set to -1 (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,904] INFO Created server with tickTime 3000 minSessionTimeout 6000 maxSessionTimeout 60000 clientPortListenBacklog -1 datadir /tmp/zookeeper/version-2 snapdir /tmp/zookeeper/version-2 (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,908] INFO Using org.apache.zookeeper.server.NIOServerCnxnFactory as server connection factory (org.apache.zookeeper.server.ServerCnxnFactory)
+[2021-12-23 18:21:57,909] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory)
+[2021-12-23 18:21:57,909] INFO Configuring NIO connection handler with 10s sessionless connection timeout, 2 selector thread(s), 16 worker threads, and 64 kB direct buffers. (org.apache.zookeeper.server.NIOServerCnxnFactory)
+[2021-12-23 18:21:57,911] INFO binding to port 0.0.0.0/0.0.0.0:2181 (org.apache.zookeeper.server.NIOServerCnxnFactory)
+[2021-12-23 18:21:57,918] INFO Using org.apache.zookeeper.server.watch.WatchManager as watch manager (org.apache.zookeeper.server.watch.WatchManagerFactory)
+[2021-12-23 18:21:57,918] INFO Using org.apache.zookeeper.server.watch.WatchManager as watch manager (org.apache.zookeeper.server.watch.WatchManagerFactory)
+[2021-12-23 18:21:57,918] INFO zookeeper.snapshotSizeFactor = 0.33 (org.apache.zookeeper.server.ZKDatabase)
+[2021-12-23 18:21:57,918] INFO zookeeper.commitLogCount=500 (org.apache.zookeeper.server.ZKDatabase)
+[2021-12-23 18:21:57,920] INFO zookeeper.snapshot.compression.method = CHECKED (org.apache.zookeeper.server.persistence.SnapStream)
+[2021-12-23 18:21:57,921] INFO Reading snapshot /tmp/zookeeper/version-2/snapshot.1a4 (org.apache.zookeeper.server.persistence.FileSnap)
+[2021-12-23 18:21:57,925] INFO The digest in the snapshot has digest version of 2, , with zxid as 0x1a4, and digest value as 706280997894 (org.apache.zookeeper.server.DataTree)
+[2021-12-23 18:21:57,929] INFO Snapshot loaded in 10 ms, highest zxid is 0x1a4, digest is 706280997894 (org.apache.zookeeper.server.ZKDatabase)
+[2021-12-23 18:21:57,929] INFO Snapshotting: 0x1a4 to /tmp/zookeeper/version-2/snapshot.1a4 (org.apache.zookeeper.server.persistence.FileTxnSnapLog)
+[2021-12-23 18:21:57,932] INFO Snapshot taken in 3 ms (org.apache.zookeeper.server.ZooKeeperServer)
+[2021-12-23 18:21:57,936] INFO PrepRequestProcessor (sid:0) started, reconfigEnabled=false (org.apache.zookeeper.server.PrepRequestProcessor)
+[2021-12-23 18:21:57,936] INFO zookeeper.request_throttler.shutdownTimeout = 10000 (org.apache.zookeeper.server.RequestThrottler)
+[2021-12-23 18:21:57,942] INFO Using checkIntervalMs=60000 maxPerMinute=10000 maxNeverUsedIntervalMs=0 (org.apache.zookeeper.server.ContainerManager)
+[2021-12-23 18:21:57,942] INFO ZooKeeper audit is disabled. (org.apache.zookeeper.audit.ZKAuditProvider)
+[2021-12-23 18:22:42,675] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
+[2021-12-23 18:22:42,807] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
+[2021-12-23 18:22:42,852] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler)
+[2021-12-23 18:22:42,853] INFO starting (kafka.server.KafkaServer)
+[2021-12-23 18:22:42,853] INFO Connecting to zookeeper on localhost:2181 (kafka.server.KafkaServer)
+[2021-12-23 18:22:42,860] INFO [ZooKeeperClient Kafka server] Initializing a new session to localhost:2181. (kafka.zookeeper.ZooKeeperClient)
+[2021-12-23 18:22:42,862] INFO Client environment:zookeeper.version=3.6.3--6401e4ad2087061bc6b9f80dec2d69f2e3c8660a, built on 04/08/2021 16:35 GMT (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,862] INFO Client environment:host.name=10.84.99.135 (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,862] INFO Client environment:java.version=17.0.1 (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,862] INFO Client environment:java.vendor=Eclipse Adoptium (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,862] INFO Client environment:java.home=/Library/Java/JavaVirtualMachines/temurin-17.jdk/Contents/Home (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,862] INFO Client environment:java.class.path=/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/activation-1.1.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/aopalliance-repackaged-2.6.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/argparse4j-0.7.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/audience-annotations-0.5.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/commons-cli-1.4.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/commons-lang3-3.8.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-api-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-basic-auth-extension-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-file-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-json-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-mirror-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-mirror-client-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-runtime-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/connect-transforms-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/hk2-api-2.6.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/hk2-locator-2.6.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/hk2-utils-2.6.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-annotations-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-core-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-databind-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-dataformat-csv-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-datatype-jdk8-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-jaxrs-base-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-jaxrs-json-provider-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-module-jaxb-annotations-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jackson-module-scala_2.13-2.12.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jakarta.activation-api-1.2.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jakarta.annotation-api-1.3.5.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jakarta.inject-2.6.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jakarta.validation-api-2.0.2.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jakarta.ws.rs-api-2.1.6.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jakarta.xml.bind-api-2.3.2.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/javassist-3.27.0-GA.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/javax.servlet-api-3.1.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/javax.ws.rs-api-2.1.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jaxb-api-2.3.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jersey-client-2.34.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jersey-common-2.34.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jersey-container-servlet-2.34.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jersey-container-servlet-core-2.34.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jersey-hk2-2.34.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jersey-server-2.34.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-client-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-continuation-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-http-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-io-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-security-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-server-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-servlet-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-servlets-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-util-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jetty-util-ajax-9.4.43.v20210629.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jline-3.12.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/jopt-simple-5.0.4.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-clients-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-log4j-appender-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-metadata-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-raft-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-server-common-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-shell-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-storage-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-storage-api-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-streams-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-streams-examples-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-streams-scala_2.13-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-streams-test-utils-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka-tools-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/kafka_2.13-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/log4j-1.2.17.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/lz4-java-1.7.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/maven-artifact-3.8.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/metrics-core-2.2.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/metrics-core-4.1.12.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-buffer-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-codec-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-common-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-handler-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-resolver-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-transport-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-transport-native-epoll-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/netty-transport-native-unix-common-4.1.62.Final.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/osgi-resource-locator-1.0.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/paranamer-2.8.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/plexus-utils-3.2.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/reflections-0.9.12.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/rocksdbjni-6.19.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/scala-collection-compat_2.13-2.4.4.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/scala-java8-compat_2.13-1.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/scala-library-2.13.6.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/scala-logging_2.13-3.9.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/scala-reflect-2.13.6.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/slf4j-api-1.7.30.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/slf4j-log4j12-1.7.30.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/snappy-java-1.1.8.1.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/trogdor-3.0.0.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/zookeeper-3.6.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/zookeeper-jute-3.6.3.jar:/Users/lucifer/Documents/projects/KafkaPySpark/kafka/bin/../libs/zstd-jni-1.5.0-2.jar (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,863] INFO Client environment:java.library.path=/Users/lucifer/Library/Java/Extensions:/Library/Java/Extensions:/Network/Library/Java/Extensions:/System/Library/Java/Extensions:/usr/lib/java:. (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,863] INFO Client environment:java.io.tmpdir=/var/folders/zz/zyxvpxvq6csfxvn_n0000000000000/T/ (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,863] INFO Client environment:java.compiler=<NA> (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,863] INFO Client environment:os.name=Mac OS X (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,863] INFO Client environment:os.arch=aarch64 (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,863] INFO Client environment:os.version=12.1 (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,863] INFO Client environment:user.name=root (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,863] INFO Client environment:user.home=/var/root (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,863] INFO Client environment:user.dir=/Users/lucifer/Documents/projects/KafkaPySpark/kafka (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,863] INFO Client environment:os.memory.free=1013MB (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,863] INFO Client environment:os.memory.max=1024MB (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,863] INFO Client environment:os.memory.total=1024MB (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,864] INFO Initiating client connection, connectString=localhost:2181 sessionTimeout=18000 watcher=kafka.zookeeper.ZooKeeperClient$ZooKeeperClientWatcher$@4dc8caa7 (org.apache.zookeeper.ZooKeeper)
+[2021-12-23 18:22:42,867] INFO jute.maxbuffer value is 4194304 Bytes (org.apache.zookeeper.ClientCnxnSocket)
+[2021-12-23 18:22:42,869] INFO zookeeper.request.timeout value is 0. feature enabled=false (org.apache.zookeeper.ClientCnxn)
+[2021-12-23 18:22:42,869] INFO [ZooKeeperClient Kafka server] Waiting until connected. (kafka.zookeeper.ZooKeeperClient)
+[2021-12-23 18:22:42,871] INFO Opening socket connection to server localhost/127.0.0.1:2181. (org.apache.zookeeper.ClientCnxn)
+[2021-12-23 18:22:42,871] INFO SASL config status: Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)
+[2021-12-23 18:22:42,873] INFO Socket connection established, initiating session, client: /127.0.0.1:50313, server: localhost/127.0.0.1:2181 (org.apache.zookeeper.ClientCnxn)
+[2021-12-23 18:22:42,878] INFO Creating new log file: log.1a5 (org.apache.zookeeper.server.persistence.FileTxnLog)
+[2021-12-23 18:22:42,902] INFO Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10013a1bf060000, negotiated timeout = 18000 (org.apache.zookeeper.ClientCnxn)
+[2021-12-23 18:22:42,904] INFO [ZooKeeperClient Kafka server] Connected. (kafka.zookeeper.ZooKeeperClient)
+[2021-12-23 18:22:43,218] INFO [feature-zk-node-event-process-thread]: Starting (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)
+[2021-12-23 18:22:43,312] INFO Updated cache from existing <empty> to latest FinalizedFeaturesAndEpoch(features=Features{}, epoch=0). (kafka.server.FinalizedFeatureCache)
+[2021-12-23 18:22:43,314] INFO Cluster ID = yHY_saRcQsKy7zu_p5RMjQ (kafka.server.KafkaServer)
+[2021-12-23 18:22:43,332] INFO KafkaConfig values: 
+	advertised.listeners = null
+	alter.config.policy.class.name = null
+	alter.log.dirs.replication.quota.window.num = 11
+	alter.log.dirs.replication.quota.window.size.seconds = 1
+	authorizer.class.name = 
+	auto.create.topics.enable = true
+	auto.leader.rebalance.enable = true
+	background.threads = 10
+	broker.heartbeat.interval.ms = 2000
+	broker.id = 0
+	broker.id.generation.enable = true
+	broker.rack = null
+	broker.session.timeout.ms = 9000
+	client.quota.callback.class = null
+	compression.type = producer
+	connection.failed.authentication.delay.ms = 100
+	connections.max.idle.ms = 600000
+	connections.max.reauth.ms = 0
+	control.plane.listener.name = null
+	controlled.shutdown.enable = true
+	controlled.shutdown.max.retries = 3
+	controlled.shutdown.retry.backoff.ms = 5000
+	controller.listener.names = null
+	controller.quorum.append.linger.ms = 25
+	controller.quorum.election.backoff.max.ms = 1000
+	controller.quorum.election.timeout.ms = 1000
+	controller.quorum.fetch.timeout.ms = 2000
+	controller.quorum.request.timeout.ms = 2000
+	controller.quorum.retry.backoff.ms = 20
+	controller.quorum.voters = []
+	controller.quota.window.num = 11
+	controller.quota.window.size.seconds = 1
+	controller.socket.timeout.ms = 30000
+	create.topic.policy.class.name = null
+	default.replication.factor = 1
+	delegation.token.expiry.check.interval.ms = 3600000
+	delegation.token.expiry.time.ms = 86400000
+	delegation.token.master.key = null
+	delegation.token.max.lifetime.ms = 604800000
+	delegation.token.secret.key = null
+	delete.records.purgatory.purge.interval.requests = 1
+	delete.topic.enable = true
+	fetch.max.bytes = 57671680
+	fetch.purgatory.purge.interval.requests = 1000
+	group.initial.rebalance.delay.ms = 0
+	group.max.session.timeout.ms = 1800000
+	group.max.size = 2147483647
+	group.min.session.timeout.ms = 6000
+	initial.broker.registration.timeout.ms = 60000
+	inter.broker.listener.name = null
+	inter.broker.protocol.version = 3.0-IV1
+	kafka.metrics.polling.interval.secs = 10
+	kafka.metrics.reporters = []
+	leader.imbalance.check.interval.seconds = 300
+	leader.imbalance.per.broker.percentage = 10
+	listener.security.protocol.map = PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL
+	listeners = PLAINTEXT://:9092
+	log.cleaner.backoff.ms = 15000
+	log.cleaner.dedupe.buffer.size = 134217728
+	log.cleaner.delete.retention.ms = 86400000
+	log.cleaner.enable = true
+	log.cleaner.io.buffer.load.factor = 0.9
+	log.cleaner.io.buffer.size = 524288
+	log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308
+	log.cleaner.max.compaction.lag.ms = 9223372036854775807
+	log.cleaner.min.cleanable.ratio = 0.5
+	log.cleaner.min.compaction.lag.ms = 0
+	log.cleaner.threads = 1
+	log.cleanup.policy = [delete]
+	log.dir = /tmp/kafka-logs
+	log.dirs = /tmp/kafka-logs
+	log.flush.interval.messages = 9223372036854775807
+	log.flush.interval.ms = null
+	log.flush.offset.checkpoint.interval.ms = 60000
+	log.flush.scheduler.interval.ms = 9223372036854775807
+	log.flush.start.offset.checkpoint.interval.ms = 60000
+	log.index.interval.bytes = 4096
+	log.index.size.max.bytes = 10485760
+	log.message.downconversion.enable = true
+	log.message.format.version = 3.0-IV1
+	log.message.timestamp.difference.max.ms = 9223372036854775807
+	log.message.timestamp.type = CreateTime
+	log.preallocate = false
+	log.retention.bytes = -1
+	log.retention.check.interval.ms = 300000
+	log.retention.hours = 168
+	log.retention.minutes = null
+	log.retention.ms = null
+	log.roll.hours = 168
+	log.roll.jitter.hours = 0
+	log.roll.jitter.ms = null
+	log.roll.ms = null
+	log.segment.bytes = 1073741824
+	log.segment.delete.delay.ms = 60000
+	max.connection.creation.rate = 2147483647
+	max.connections = 2147483647
+	max.connections.per.ip = 2147483647
+	max.connections.per.ip.overrides = 
+	max.incremental.fetch.session.cache.slots = 1000
+	message.max.bytes = 1048588
+	metadata.log.dir = null
+	metadata.log.max.record.bytes.between.snapshots = 20971520
+	metadata.log.segment.bytes = 1073741824
+	metadata.log.segment.min.bytes = 8388608
+	metadata.log.segment.ms = 604800000
+	metadata.max.retention.bytes = -1
+	metadata.max.retention.ms = 604800000
+	metric.reporters = []
+	metrics.num.samples = 2
+	metrics.recording.level = INFO
+	metrics.sample.window.ms = 30000
+	min.insync.replicas = 1
+	node.id = -1
+	num.io.threads = 8
+	num.network.threads = 3
+	num.partitions = 1
+	num.recovery.threads.per.data.dir = 1
+	num.replica.alter.log.dirs.threads = null
+	num.replica.fetchers = 1
+	offset.metadata.max.bytes = 4096
+	offsets.commit.required.acks = -1
+	offsets.commit.timeout.ms = 5000
+	offsets.load.buffer.size = 5242880
+	offsets.retention.check.interval.ms = 600000
+	offsets.retention.minutes = 10080
+	offsets.topic.compression.codec = 0
+	offsets.topic.num.partitions = 50
+	offsets.topic.replication.factor = 1
+	offsets.topic.segment.bytes = 104857600
+	password.encoder.cipher.algorithm = AES/CBC/PKCS5Padding
+	password.encoder.iterations = 4096
+	password.encoder.key.length = 128
+	password.encoder.keyfactory.algorithm = null
+	password.encoder.old.secret = null
+	password.encoder.secret = null
+	principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder
+	process.roles = []
+	producer.purgatory.purge.interval.requests = 1000
+	queued.max.request.bytes = -1
+	queued.max.requests = 500
+	quota.window.num = 11
+	quota.window.size.seconds = 1
+	remote.log.index.file.cache.total.size.bytes = 1073741824
+	remote.log.manager.task.interval.ms = 30000
+	remote.log.manager.task.retry.backoff.max.ms = 30000
+	remote.log.manager.task.retry.backoff.ms = 500
+	remote.log.manager.task.retry.jitter = 0.2
+	remote.log.manager.thread.pool.size = 10
+	remote.log.metadata.manager.class.name = null
+	remote.log.metadata.manager.class.path = null
+	remote.log.metadata.manager.impl.prefix = null
+	remote.log.metadata.manager.listener.name = null
+	remote.log.reader.max.pending.tasks = 100
+	remote.log.reader.threads = 10
+	remote.log.storage.manager.class.name = null
+	remote.log.storage.manager.class.path = null
+	remote.log.storage.manager.impl.prefix = null
+	remote.log.storage.system.enable = false
+	replica.fetch.backoff.ms = 1000
+	replica.fetch.max.bytes = 1048576
+	replica.fetch.min.bytes = 1
+	replica.fetch.response.max.bytes = 10485760
+	replica.fetch.wait.max.ms = 500
+	replica.high.watermark.checkpoint.interval.ms = 5000
+	replica.lag.time.max.ms = 30000
+	replica.selector.class = null
+	replica.socket.receive.buffer.bytes = 65536
+	replica.socket.timeout.ms = 30000
+	replication.quota.window.num = 11
+	replication.quota.window.size.seconds = 1
+	request.timeout.ms = 30000
+	reserved.broker.max.id = 1000
+	sasl.client.callback.handler.class = null
+	sasl.enabled.mechanisms = [GSSAPI]
+	sasl.jaas.config = null
+	sasl.kerberos.kinit.cmd = /usr/bin/kinit
+	sasl.kerberos.min.time.before.relogin = 60000
+	sasl.kerberos.principal.to.local.rules = [DEFAULT]
+	sasl.kerberos.service.name = null
+	sasl.kerberos.ticket.renew.jitter = 0.05
+	sasl.kerberos.ticket.renew.window.factor = 0.8
+	sasl.login.callback.handler.class = null
+	sasl.login.class = null
+	sasl.login.refresh.buffer.seconds = 300
+	sasl.login.refresh.min.period.seconds = 60
+	sasl.login.refresh.window.factor = 0.8
+	sasl.login.refresh.window.jitter = 0.05
+	sasl.mechanism.controller.protocol = GSSAPI
+	sasl.mechanism.inter.broker.protocol = GSSAPI
+	sasl.server.callback.handler.class = null
+	security.inter.broker.protocol = PLAINTEXT
+	security.providers = null
+	socket.connection.setup.timeout.max.ms = 30000
+	socket.connection.setup.timeout.ms = 10000
+	socket.receive.buffer.bytes = 102400
+	socket.request.max.bytes = 104857600
+	socket.send.buffer.bytes = 102400
+	ssl.cipher.suites = []
+	ssl.client.auth = none
+	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
+	ssl.endpoint.identification.algorithm = https
+	ssl.engine.factory.class = null
+	ssl.key.password = null
+	ssl.keymanager.algorithm = SunX509
+	ssl.keystore.certificate.chain = null
+	ssl.keystore.key = null
+	ssl.keystore.location = null
+	ssl.keystore.password = null
+	ssl.keystore.type = JKS
+	ssl.principal.mapping.rules = DEFAULT
+	ssl.protocol = TLSv1.3
+	ssl.provider = null
+	ssl.secure.random.implementation = null
+	ssl.trustmanager.algorithm = PKIX
+	ssl.truststore.certificates = null
+	ssl.truststore.location = null
+	ssl.truststore.password = null
+	ssl.truststore.type = JKS
+	transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000
+	transaction.max.timeout.ms = 900000
+	transaction.remove.expired.transaction.cleanup.interval.ms = 3600000
+	transaction.state.log.load.buffer.size = 5242880
+	transaction.state.log.min.isr = 1
+	transaction.state.log.num.partitions = 50
+	transaction.state.log.replication.factor = 1
+	transaction.state.log.segment.bytes = 104857600
+	transactional.id.expiration.ms = 604800000
+	unclean.leader.election.enable = false
+	zookeeper.clientCnxnSocket = null
+	zookeeper.connect = localhost:2181
+	zookeeper.connection.timeout.ms = 18000
+	zookeeper.max.in.flight.requests = 10
+	zookeeper.session.timeout.ms = 18000
+	zookeeper.set.acl = false
+	zookeeper.ssl.cipher.suites = null
+	zookeeper.ssl.client.enable = false
+	zookeeper.ssl.crl.enable = false
+	zookeeper.ssl.enabled.protocols = null
+	zookeeper.ssl.endpoint.identification.algorithm = HTTPS
+	zookeeper.ssl.keystore.location = null
+	zookeeper.ssl.keystore.password = null
+	zookeeper.ssl.keystore.type = null
+	zookeeper.ssl.ocsp.enable = false
+	zookeeper.ssl.protocol = TLSv1.2
+	zookeeper.ssl.truststore.location = null
+	zookeeper.ssl.truststore.password = null
+	zookeeper.ssl.truststore.type = null
+	zookeeper.sync.time.ms = 2000
+ (kafka.server.KafkaConfig)
+[2021-12-23 18:22:43,336] INFO KafkaConfig values: 
+	advertised.listeners = null
+	alter.config.policy.class.name = null
+	alter.log.dirs.replication.quota.window.num = 11
+	alter.log.dirs.replication.quota.window.size.seconds = 1
+	authorizer.class.name = 
+	auto.create.topics.enable = true
+	auto.leader.rebalance.enable = true
+	background.threads = 10
+	broker.heartbeat.interval.ms = 2000
+	broker.id = 0
+	broker.id.generation.enable = true
+	broker.rack = null
+	broker.session.timeout.ms = 9000
+	client.quota.callback.class = null
+	compression.type = producer
+	connection.failed.authentication.delay.ms = 100
+	connections.max.idle.ms = 600000
+	connections.max.reauth.ms = 0
+	control.plane.listener.name = null
+	controlled.shutdown.enable = true
+	controlled.shutdown.max.retries = 3
+	controlled.shutdown.retry.backoff.ms = 5000
+	controller.listener.names = null
+	controller.quorum.append.linger.ms = 25
+	controller.quorum.election.backoff.max.ms = 1000
+	controller.quorum.election.timeout.ms = 1000
+	controller.quorum.fetch.timeout.ms = 2000
+	controller.quorum.request.timeout.ms = 2000
+	controller.quorum.retry.backoff.ms = 20
+	controller.quorum.voters = []
+	controller.quota.window.num = 11
+	controller.quota.window.size.seconds = 1
+	controller.socket.timeout.ms = 30000
+	create.topic.policy.class.name = null
+	default.replication.factor = 1
+	delegation.token.expiry.check.interval.ms = 3600000
+	delegation.token.expiry.time.ms = 86400000
+	delegation.token.master.key = null
+	delegation.token.max.lifetime.ms = 604800000
+	delegation.token.secret.key = null
+	delete.records.purgatory.purge.interval.requests = 1
+	delete.topic.enable = true
+	fetch.max.bytes = 57671680
+	fetch.purgatory.purge.interval.requests = 1000
+	group.initial.rebalance.delay.ms = 0
+	group.max.session.timeout.ms = 1800000
+	group.max.size = 2147483647
+	group.min.session.timeout.ms = 6000
+	initial.broker.registration.timeout.ms = 60000
+	inter.broker.listener.name = null
+	inter.broker.protocol.version = 3.0-IV1
+	kafka.metrics.polling.interval.secs = 10
+	kafka.metrics.reporters = []
+	leader.imbalance.check.interval.seconds = 300
+	leader.imbalance.per.broker.percentage = 10
+	listener.security.protocol.map = PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL
+	listeners = PLAINTEXT://:9092
+	log.cleaner.backoff.ms = 15000
+	log.cleaner.dedupe.buffer.size = 134217728
+	log.cleaner.delete.retention.ms = 86400000
+	log.cleaner.enable = true
+	log.cleaner.io.buffer.load.factor = 0.9
+	log.cleaner.io.buffer.size = 524288
+	log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308
+	log.cleaner.max.compaction.lag.ms = 9223372036854775807
+	log.cleaner.min.cleanable.ratio = 0.5
+	log.cleaner.min.compaction.lag.ms = 0
+	log.cleaner.threads = 1
+	log.cleanup.policy = [delete]
+	log.dir = /tmp/kafka-logs
+	log.dirs = /tmp/kafka-logs
+	log.flush.interval.messages = 9223372036854775807
+	log.flush.interval.ms = null
+	log.flush.offset.checkpoint.interval.ms = 60000
+	log.flush.scheduler.interval.ms = 9223372036854775807
+	log.flush.start.offset.checkpoint.interval.ms = 60000
+	log.index.interval.bytes = 4096
+	log.index.size.max.bytes = 10485760
+	log.message.downconversion.enable = true
+	log.message.format.version = 3.0-IV1
+	log.message.timestamp.difference.max.ms = 9223372036854775807
+	log.message.timestamp.type = CreateTime
+	log.preallocate = false
+	log.retention.bytes = -1
+	log.retention.check.interval.ms = 300000
+	log.retention.hours = 168
+	log.retention.minutes = null
+	log.retention.ms = null
+	log.roll.hours = 168
+	log.roll.jitter.hours = 0
+	log.roll.jitter.ms = null
+	log.roll.ms = null
+	log.segment.bytes = 1073741824
+	log.segment.delete.delay.ms = 60000
+	max.connection.creation.rate = 2147483647
+	max.connections = 2147483647
+	max.connections.per.ip = 2147483647
+	max.connections.per.ip.overrides = 
+	max.incremental.fetch.session.cache.slots = 1000
+	message.max.bytes = 1048588
+	metadata.log.dir = null
+	metadata.log.max.record.bytes.between.snapshots = 20971520
+	metadata.log.segment.bytes = 1073741824
+	metadata.log.segment.min.bytes = 8388608
+	metadata.log.segment.ms = 604800000
+	metadata.max.retention.bytes = -1
+	metadata.max.retention.ms = 604800000
+	metric.reporters = []
+	metrics.num.samples = 2
+	metrics.recording.level = INFO
+	metrics.sample.window.ms = 30000
+	min.insync.replicas = 1
+	node.id = -1
+	num.io.threads = 8
+	num.network.threads = 3
+	num.partitions = 1
+	num.recovery.threads.per.data.dir = 1
+	num.replica.alter.log.dirs.threads = null
+	num.replica.fetchers = 1
+	offset.metadata.max.bytes = 4096
+	offsets.commit.required.acks = -1
+	offsets.commit.timeout.ms = 5000
+	offsets.load.buffer.size = 5242880
+	offsets.retention.check.interval.ms = 600000
+	offsets.retention.minutes = 10080
+	offsets.topic.compression.codec = 0
+	offsets.topic.num.partitions = 50
+	offsets.topic.replication.factor = 1
+	offsets.topic.segment.bytes = 104857600
+	password.encoder.cipher.algorithm = AES/CBC/PKCS5Padding
+	password.encoder.iterations = 4096
+	password.encoder.key.length = 128
+	password.encoder.keyfactory.algorithm = null
+	password.encoder.old.secret = null
+	password.encoder.secret = null
+	principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder
+	process.roles = []
+	producer.purgatory.purge.interval.requests = 1000
+	queued.max.request.bytes = -1
+	queued.max.requests = 500
+	quota.window.num = 11
+	quota.window.size.seconds = 1
+	remote.log.index.file.cache.total.size.bytes = 1073741824
+	remote.log.manager.task.interval.ms = 30000
+	remote.log.manager.task.retry.backoff.max.ms = 30000
+	remote.log.manager.task.retry.backoff.ms = 500
+	remote.log.manager.task.retry.jitter = 0.2
+	remote.log.manager.thread.pool.size = 10
+	remote.log.metadata.manager.class.name = null
+	remote.log.metadata.manager.class.path = null
+	remote.log.metadata.manager.impl.prefix = null
+	remote.log.metadata.manager.listener.name = null
+	remote.log.reader.max.pending.tasks = 100
+	remote.log.reader.threads = 10
+	remote.log.storage.manager.class.name = null
+	remote.log.storage.manager.class.path = null
+	remote.log.storage.manager.impl.prefix = null
+	remote.log.storage.system.enable = false
+	replica.fetch.backoff.ms = 1000
+	replica.fetch.max.bytes = 1048576
+	replica.fetch.min.bytes = 1
+	replica.fetch.response.max.bytes = 10485760
+	replica.fetch.wait.max.ms = 500
+	replica.high.watermark.checkpoint.interval.ms = 5000
+	replica.lag.time.max.ms = 30000
+	replica.selector.class = null
+	replica.socket.receive.buffer.bytes = 65536
+	replica.socket.timeout.ms = 30000
+	replication.quota.window.num = 11
+	replication.quota.window.size.seconds = 1
+	request.timeout.ms = 30000
+	reserved.broker.max.id = 1000
+	sasl.client.callback.handler.class = null
+	sasl.enabled.mechanisms = [GSSAPI]
+	sasl.jaas.config = null
+	sasl.kerberos.kinit.cmd = /usr/bin/kinit
+	sasl.kerberos.min.time.before.relogin = 60000
+	sasl.kerberos.principal.to.local.rules = [DEFAULT]
+	sasl.kerberos.service.name = null
+	sasl.kerberos.ticket.renew.jitter = 0.05
+	sasl.kerberos.ticket.renew.window.factor = 0.8
+	sasl.login.callback.handler.class = null
+	sasl.login.class = null
+	sasl.login.refresh.buffer.seconds = 300
+	sasl.login.refresh.min.period.seconds = 60
+	sasl.login.refresh.window.factor = 0.8
+	sasl.login.refresh.window.jitter = 0.05
+	sasl.mechanism.controller.protocol = GSSAPI
+	sasl.mechanism.inter.broker.protocol = GSSAPI
+	sasl.server.callback.handler.class = null
+	security.inter.broker.protocol = PLAINTEXT
+	security.providers = null
+	socket.connection.setup.timeout.max.ms = 30000
+	socket.connection.setup.timeout.ms = 10000
+	socket.receive.buffer.bytes = 102400
+	socket.request.max.bytes = 104857600
+	socket.send.buffer.bytes = 102400
+	ssl.cipher.suites = []
+	ssl.client.auth = none
+	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
+	ssl.endpoint.identification.algorithm = https
+	ssl.engine.factory.class = null
+	ssl.key.password = null
+	ssl.keymanager.algorithm = SunX509
+	ssl.keystore.certificate.chain = null
+	ssl.keystore.key = null
+	ssl.keystore.location = null
+	ssl.keystore.password = null
+	ssl.keystore.type = JKS
+	ssl.principal.mapping.rules = DEFAULT
+	ssl.protocol = TLSv1.3
+	ssl.provider = null
+	ssl.secure.random.implementation = null
+	ssl.trustmanager.algorithm = PKIX
+	ssl.truststore.certificates = null
+	ssl.truststore.location = null
+	ssl.truststore.password = null
+	ssl.truststore.type = JKS
+	transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000
+	transaction.max.timeout.ms = 900000
+	transaction.remove.expired.transaction.cleanup.interval.ms = 3600000
+	transaction.state.log.load.buffer.size = 5242880
+	transaction.state.log.min.isr = 1
+	transaction.state.log.num.partitions = 50
+	transaction.state.log.replication.factor = 1
+	transaction.state.log.segment.bytes = 104857600
+	transactional.id.expiration.ms = 604800000
+	unclean.leader.election.enable = false
+	zookeeper.clientCnxnSocket = null
+	zookeeper.connect = localhost:2181
+	zookeeper.connection.timeout.ms = 18000
+	zookeeper.max.in.flight.requests = 10
+	zookeeper.session.timeout.ms = 18000
+	zookeeper.set.acl = false
+	zookeeper.ssl.cipher.suites = null
+	zookeeper.ssl.client.enable = false
+	zookeeper.ssl.crl.enable = false
+	zookeeper.ssl.enabled.protocols = null
+	zookeeper.ssl.endpoint.identification.algorithm = HTTPS
+	zookeeper.ssl.keystore.location = null
+	zookeeper.ssl.keystore.password = null
+	zookeeper.ssl.keystore.type = null
+	zookeeper.ssl.ocsp.enable = false
+	zookeeper.ssl.protocol = TLSv1.2
+	zookeeper.ssl.truststore.location = null
+	zookeeper.ssl.truststore.password = null
+	zookeeper.ssl.truststore.type = null
+	zookeeper.sync.time.ms = 2000
+ (kafka.server.KafkaConfig)
+[2021-12-23 18:22:43,352] INFO [ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
+[2021-12-23 18:22:43,352] INFO [ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
+[2021-12-23 18:22:43,353] INFO [ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
+[2021-12-23 18:22:43,353] INFO [ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
+[2021-12-23 18:22:43,375] INFO Loading logs from log dirs ArraySeq(/tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,377] INFO Skipping recovery for all logs in /tmp/kafka-logs since clean shutdown file was found (kafka.log.LogManager)
+[2021-12-23 18:22:43,432] INFO [LogLoader partition=_confluent_balancer_broker_samples-15, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,441] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-15, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=15, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 57ms (1/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,462] INFO [LogLoader partition=__consumer_offsets-9, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,463] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-9, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=9, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (2/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,484] INFO [LogLoader partition=_confluent_balancer_broker_samples-12, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,485] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-12, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=12, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 23ms (3/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,507] INFO [LogLoader partition=_confluent_balancer_broker_samples-24, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,508] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-24, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=24, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (4/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,529] INFO [LogLoader partition=__consumer_offsets-0, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,530] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-0, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (5/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,551] INFO [LogLoader partition=_confluent_balancer_broker_samples-23, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,552] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-23, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=23, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (6/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,573] INFO [LogLoader partition=__consumer_offsets-7, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,574] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-7, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=7, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (7/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,596] INFO [LogLoader partition=__consumer_offsets-31, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,597] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-31, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=31, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (8/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,618] INFO [LogLoader partition=__consumer_offsets-36, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,619] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-36, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=36, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (9/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,641] INFO [LogLoader partition=__consumer_offsets-38, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,642] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-38, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=38, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 23ms (10/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,663] INFO [LogLoader partition=_confluent_balancer_broker_samples-22, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,664] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-22, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=22, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (11/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,685] INFO [LogLoader partition=__consumer_offsets-6, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,686] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-6, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=6, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (12/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,707] INFO [LogLoader partition=_confluent_balancer_broker_samples-25, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,708] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-25, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=25, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (13/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,730] INFO [LogLoader partition=__consumer_offsets-1, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,731] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-1, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=1, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 23ms (14/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,752] INFO [LogLoader partition=_confluent_balancer_broker_samples-13, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,753] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-13, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=13, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (15/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,773] INFO [LogLoader partition=__consumer_offsets-8, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,774] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-8, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=8, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (16/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,795] INFO [LogLoader partition=_confluent_balancer_broker_samples-14, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,796] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-14, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=14, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (17/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,817] INFO [LogLoader partition=__consumer_offsets-39, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,818] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-39, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=39, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (18/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,839] INFO [LogLoader partition=__consumer_offsets-37, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,840] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-37, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=37, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (19/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,861] INFO [LogLoader partition=__consumer_offsets-30, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,862] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-30, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=30, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (20/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,882] INFO [LogLoader partition=_confluent_balancer_partition_samples-9, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,883] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-9, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=9, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (21/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,909] INFO [LogLoader partition=_confluent-telemetry-metrics-2, dir=/tmp/kafka-logs] Loading producer state till offset 197 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,909] INFO [LogLoader partition=_confluent-telemetry-metrics-2, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 197 (kafka.log.Log$)
+[2021-12-23 18:22:43,910] INFO [ProducerStateManager partition=_confluent-telemetry-metrics-2] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/_confluent-telemetry-metrics-2/00000000000000000197.snapshot,197)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:43,914] INFO [LogLoader partition=_confluent-telemetry-metrics-2, dir=/tmp/kafka-logs] Producer state recovery took 5ms for snapshot load and 0ms for segment recovery from offset 197 (kafka.log.Log$)
+[2021-12-23 18:22:43,915] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent-telemetry-metrics-2, topicId=EA3LM6xqTimFIekTgVXD2w, topic=_confluent-telemetry-metrics, partition=2, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=197) with 1 segments in 32ms (22/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,937] INFO [LogLoader partition=_confluent_balancer_partition_samples-0, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,938] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-0, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (23/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,959] INFO [LogLoader partition=_confluent-telemetry-metrics-5, dir=/tmp/kafka-logs] Loading producer state till offset 419 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,959] INFO [LogLoader partition=_confluent-telemetry-metrics-5, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 419 (kafka.log.Log$)
+[2021-12-23 18:22:43,959] INFO [ProducerStateManager partition=_confluent-telemetry-metrics-5] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/_confluent-telemetry-metrics-5/00000000000000000419.snapshot,419)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:43,959] INFO [LogLoader partition=_confluent-telemetry-metrics-5, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 419 (kafka.log.Log$)
+[2021-12-23 18:22:43,960] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent-telemetry-metrics-5, topicId=EA3LM6xqTimFIekTgVXD2w, topic=_confluent-telemetry-metrics, partition=5, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=419) with 1 segments in 22ms (24/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:43,981] INFO [LogLoader partition=_confluent_balancer_partition_samples-7, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:43,982] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-7, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=7, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (25/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,004] INFO [LogLoader partition=_confluent-telemetry-metrics-4, dir=/tmp/kafka-logs] Loading producer state till offset 447 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,004] INFO [LogLoader partition=_confluent-telemetry-metrics-4, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 447 (kafka.log.Log$)
+[2021-12-23 18:22:44,004] INFO [ProducerStateManager partition=_confluent-telemetry-metrics-4] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/_confluent-telemetry-metrics-4/00000000000000000447.snapshot,447)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:44,004] INFO [LogLoader partition=_confluent-telemetry-metrics-4, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 447 (kafka.log.Log$)
+[2021-12-23 18:22:44,005] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent-telemetry-metrics-4, topicId=EA3LM6xqTimFIekTgVXD2w, topic=_confluent-telemetry-metrics, partition=4, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=447) with 1 segments in 23ms (26/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,024] INFO [LogLoader partition=_confluent_balancer_partition_samples-6, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,025] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-6, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=6, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 20ms (27/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,046] INFO [LogLoader partition=_confluent-telemetry-metrics-3, dir=/tmp/kafka-logs] Loading producer state till offset 735 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,046] INFO [LogLoader partition=_confluent-telemetry-metrics-3, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 735 (kafka.log.Log$)
+[2021-12-23 18:22:44,046] INFO [ProducerStateManager partition=_confluent-telemetry-metrics-3] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/_confluent-telemetry-metrics-3/00000000000000000735.snapshot,735)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:44,046] INFO [LogLoader partition=_confluent-telemetry-metrics-3, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 735 (kafka.log.Log$)
+[2021-12-23 18:22:44,047] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent-telemetry-metrics-3, topicId=EA3LM6xqTimFIekTgVXD2w, topic=_confluent-telemetry-metrics, partition=3, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=735) with 1 segments in 22ms (28/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,067] INFO [LogLoader partition=_confluent_balancer_partition_samples-1, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,068] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-1, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=1, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (29/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,088] INFO [LogLoader partition=_confluent_balancer_partition_samples-8, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,088] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-8, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=8, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 20ms (30/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,109] INFO [LogLoader partition=_confluent-telemetry-metrics-10, dir=/tmp/kafka-logs] Loading producer state till offset 375 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,109] INFO [LogLoader partition=_confluent-telemetry-metrics-10, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 375 (kafka.log.Log$)
+[2021-12-23 18:22:44,109] INFO [ProducerStateManager partition=_confluent-telemetry-metrics-10] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/_confluent-telemetry-metrics-10/00000000000000000375.snapshot,375)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:44,109] INFO [LogLoader partition=_confluent-telemetry-metrics-10, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 375 (kafka.log.Log$)
+[2021-12-23 18:22:44,110] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent-telemetry-metrics-10, topicId=EA3LM6xqTimFIekTgVXD2w, topic=_confluent-telemetry-metrics, partition=10, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=375) with 1 segments in 21ms (31/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,131] INFO [LogLoader partition=_confluent-telemetry-metrics-11, dir=/tmp/kafka-logs] Loading producer state till offset 326 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,131] INFO [LogLoader partition=_confluent-telemetry-metrics-11, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 326 (kafka.log.Log$)
+[2021-12-23 18:22:44,131] INFO [ProducerStateManager partition=_confluent-telemetry-metrics-11] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/_confluent-telemetry-metrics-11/00000000000000000326.snapshot,326)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:44,131] INFO [LogLoader partition=_confluent-telemetry-metrics-11, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 326 (kafka.log.Log$)
+[2021-12-23 18:22:44,132] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent-telemetry-metrics-11, topicId=EA3LM6xqTimFIekTgVXD2w, topic=_confluent-telemetry-metrics, partition=11, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=326) with 1 segments in 22ms (32/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,152] INFO [LogLoader partition=_confluent_balancer_partition_samples-20, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,153] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-20, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=20, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (33/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,173] INFO [LogLoader partition=__consumer_offsets-12, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,173] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-12, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=12, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 20ms (34/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,194] INFO [LogLoader partition=_confluent_balancer_partition_samples-27, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,195] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-27, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=27, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (35/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,215] INFO [LogLoader partition=_confluent_balancer_partition_samples-18, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,216] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-18, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=18, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (36/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,236] INFO [LogLoader partition=__consumer_offsets-15, dir=/tmp/kafka-logs] Loading producer state till offset 2 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,236] INFO [LogLoader partition=__consumer_offsets-15, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,236] INFO [ProducerStateManager partition=__consumer_offsets-15] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/__consumer_offsets-15/00000000000000000002.snapshot,2)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:44,237] INFO [LogLoader partition=__consumer_offsets-15, dir=/tmp/kafka-logs] Producer state recovery took 1ms for snapshot load and 0ms for segment recovery from offset 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,237] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-15, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=15, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=2) with 1 segments in 21ms (37/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,258] INFO [LogLoader partition=_confluent_balancer_partition_samples-11, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,258] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-11, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=11, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (38/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,279] INFO [LogLoader partition=__consumer_offsets-23, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,280] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-23, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=23, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (39/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,300] INFO [LogLoader partition=_confluent_balancer_partition_samples-16, dir=/tmp/kafka-logs] Loading producer state till offset 129 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,300] INFO [LogLoader partition=_confluent_balancer_partition_samples-16, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 129 (kafka.log.Log$)
+[2021-12-23 18:22:44,300] INFO [ProducerStateManager partition=_confluent_balancer_partition_samples-16] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/_confluent_balancer_partition_samples-16/00000000000000000129.snapshot,129)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:44,300] INFO [LogLoader partition=_confluent_balancer_partition_samples-16, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 129 (kafka.log.Log$)
+[2021-12-23 18:22:44,301] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-16, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=16, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=129) with 1 segments in 21ms (40/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,327] INFO [LogLoader partition=_confluent_balancer_partition_samples-29, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,328] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-29, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=29, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 27ms (41/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,349] INFO [LogLoader partition=__consumer_offsets-24, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,349] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-24, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=24, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (42/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,370] INFO [LogLoader partition=_confluent_balancer_broker_samples-2, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,371] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-2, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=2, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (43/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,392] INFO [LogLoader partition=_confluent_balancer_broker_samples-5, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,392] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-5, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=5, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (44/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,413] INFO [LogLoader partition=_confluent_balancer_broker_samples-31, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,414] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-31, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=31, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (45/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,436] INFO [LogLoader partition=__consumer_offsets-48, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,437] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-48, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=48, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 23ms (46/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,458] INFO [LogLoader partition=__consumer_offsets-41, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,459] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-41, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=41, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (47/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,479] INFO [LogLoader partition=__consumer_offsets-46, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,480] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-46, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=46, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (48/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,501] INFO [LogLoader partition=_confluent_balancer_partition_samples-17, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,502] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-17, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=17, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (49/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,523] INFO [LogLoader partition=__consumer_offsets-25, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,523] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-25, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=25, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (50/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,544] INFO [LogLoader partition=_confluent_balancer_partition_samples-28, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,545] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-28, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=28, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (51/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,566] INFO [LogLoader partition=_confluent_balancer_partition_samples-10, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,566] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-10, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=10, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (52/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,587] INFO [LogLoader partition=__consumer_offsets-22, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,588] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-22, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=22, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (53/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,609] INFO [LogLoader partition=_confluent_balancer_partition_samples-26, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,610] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-26, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=26, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (54/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,631] INFO [LogLoader partition=__consumer_offsets-14, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,632] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-14, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=14, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (55/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,652] INFO [LogLoader partition=_confluent_balancer_partition_samples-19, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,653] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-19, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=19, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (56/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,673] INFO [LogLoader partition=_confluent_balancer_partition_samples-21, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,674] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-21, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=21, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (57/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,711] INFO [LogLoader partition=__consumer_offsets-13, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,712] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-13, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=13, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 38ms (58/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,733] INFO [LogLoader partition=__consumer_offsets-47, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,734] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-47, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=47, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (59/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,755] INFO [LogLoader partition=__consumer_offsets-40, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,756] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-40, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=40, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (60/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,777] INFO [LogLoader partition=_confluent_balancer_broker_samples-4, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,784] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-4, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=4, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 28ms (61/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,805] INFO [LogLoader partition=__consumer_offsets-49, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,806] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-49, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=49, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (62/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,827] INFO [LogLoader partition=_confluent_balancer_broker_samples-30, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,828] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-30, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=30, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (63/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,850] INFO [LogLoader partition=_confluent_balancer_broker_samples-3, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,851] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-3, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=3, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 23ms (64/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,872] INFO [LogLoader partition=__consumer_offsets-35, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,872] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-35, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=35, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (65/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,893] INFO [LogLoader partition=__consumer_offsets-32, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,894] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-32, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=32, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (66/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,914] INFO [LogLoader partition=_confluent_balancer_api_state-0, dir=/tmp/kafka-logs] Loading producer state till offset 1 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,914] INFO [LogLoader partition=_confluent_balancer_api_state-0, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 1 (kafka.log.Log$)
+[2021-12-23 18:22:44,914] INFO [ProducerStateManager partition=_confluent_balancer_api_state-0] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/_confluent_balancer_api_state-0/00000000000000000001.snapshot,1)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:44,914] INFO [LogLoader partition=_confluent_balancer_api_state-0, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 1 (kafka.log.Log$)
+[2021-12-23 18:22:44,915] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_api_state-0, topicId=Xw3gNsI3T4CcnMS9Bu0lYA, topic=_confluent_balancer_api_state, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=1) with 1 segments in 21ms (67/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,935] INFO [LogLoader partition=_confluent_balancer_partition_samples-31, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,936] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-31, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=31, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (68/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,956] INFO [LogLoader partition=_confluent_balancer_broker_samples-11, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,956] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-11, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=11, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 20ms (69/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,977] INFO [LogLoader partition=_confluent_balancer_broker_samples-16, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,978] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-16, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=16, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (70/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:44,997] INFO [LogLoader partition=_confluent_balancer_broker_samples-29, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:44,997] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-29, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=29, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 19ms (71/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,018] INFO [LogLoader partition=_confluent_balancer_broker_samples-20, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,019] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-20, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=20, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (72/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,040] INFO [LogLoader partition=__consumer_offsets-4, dir=/tmp/kafka-logs] Loading producer state till offset 1 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,040] INFO [LogLoader partition=__consumer_offsets-4, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 1 (kafka.log.Log$)
+[2021-12-23 18:22:45,040] INFO [ProducerStateManager partition=__consumer_offsets-4] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/__consumer_offsets-4/00000000000000000001.snapshot,1)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:45,040] INFO [LogLoader partition=__consumer_offsets-4, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 1 (kafka.log.Log$)
+[2021-12-23 18:22:45,041] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-4, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=4, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=1) with 1 segments in 22ms (73/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,063] INFO [LogLoader partition=_confluent_balancer_broker_samples-27, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,064] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-27, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=27, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 23ms (74/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,084] INFO [LogLoader partition=__consumer_offsets-3, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,084] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-3, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=3, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (75/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,105] INFO [LogLoader partition=_confluent_balancer_broker_samples-18, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,106] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-18, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=18, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (76/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,126] INFO [LogLoader partition=_confluent_balancer_partition_samples-30, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,126] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-30, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=30, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 20ms (77/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,147] INFO [LogLoader partition=__consumer_offsets-33, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,148] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-33, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=33, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (78/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,169] INFO [LogLoader partition=__consumer_offsets-34, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,169] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-34, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=34, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (79/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,190] INFO [LogLoader partition=_confluent_balancer_broker_samples-26, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,191] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-26, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=26, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (80/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,212] INFO [LogLoader partition=_confluent_balancer_broker_samples-19, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,213] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-19, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=19, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (81/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,234] INFO [LogLoader partition=__consumer_offsets-2, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,235] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-2, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=2, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (82/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,256] INFO [LogLoader partition=_confluent_balancer_broker_samples-21, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,256] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-21, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=21, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (83/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,277] INFO [LogLoader partition=__consumer_offsets-5, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,277] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-5, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=5, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (84/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,298] INFO [LogLoader partition=_confluent_balancer_broker_samples-17, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,298] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-17, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=17, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 20ms (85/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,319] INFO [LogLoader partition=_confluent_balancer_broker_samples-28, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,320] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-28, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=28, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (86/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,339] INFO [LogLoader partition=_confluent_balancer_broker_samples-10, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,340] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-10, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=10, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 20ms (87/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,361] INFO [LogLoader partition=_confluent-telemetry-metrics-8, dir=/tmp/kafka-logs] Loading producer state till offset 661 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,361] INFO [LogLoader partition=_confluent-telemetry-metrics-8, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 661 (kafka.log.Log$)
+[2021-12-23 18:22:45,361] INFO [ProducerStateManager partition=_confluent-telemetry-metrics-8] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/_confluent-telemetry-metrics-8/00000000000000000661.snapshot,661)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:45,361] INFO [LogLoader partition=_confluent-telemetry-metrics-8, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 661 (kafka.log.Log$)
+[2021-12-23 18:22:45,362] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent-telemetry-metrics-8, topicId=EA3LM6xqTimFIekTgVXD2w, topic=_confluent-telemetry-metrics, partition=8, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=661) with 1 segments in 22ms (88/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,383] INFO [LogLoader partition=_confluent-telemetry-metrics-6, dir=/tmp/kafka-logs] Loading producer state till offset 227 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,383] INFO [LogLoader partition=_confluent-telemetry-metrics-6, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 227 (kafka.log.Log$)
+[2021-12-23 18:22:45,383] INFO [ProducerStateManager partition=_confluent-telemetry-metrics-6] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/_confluent-telemetry-metrics-6/00000000000000000227.snapshot,227)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:45,383] INFO [LogLoader partition=_confluent-telemetry-metrics-6, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 227 (kafka.log.Log$)
+[2021-12-23 18:22:45,383] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent-telemetry-metrics-6, topicId=EA3LM6xqTimFIekTgVXD2w, topic=_confluent-telemetry-metrics, partition=6, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=227) with 1 segments in 22ms (89/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,404] INFO [LogLoader partition=_confluent_balancer_partition_samples-4, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,404] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-4, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=4, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (90/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,425] INFO [LogLoader partition=_confluent-telemetry-metrics-1, dir=/tmp/kafka-logs] Loading producer state till offset 187 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,425] INFO [LogLoader partition=_confluent-telemetry-metrics-1, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 187 (kafka.log.Log$)
+[2021-12-23 18:22:45,425] INFO [ProducerStateManager partition=_confluent-telemetry-metrics-1] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/_confluent-telemetry-metrics-1/00000000000000000187.snapshot,187)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:45,425] INFO [LogLoader partition=_confluent-telemetry-metrics-1, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 187 (kafka.log.Log$)
+[2021-12-23 18:22:45,426] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent-telemetry-metrics-1, topicId=EA3LM6xqTimFIekTgVXD2w, topic=_confluent-telemetry-metrics, partition=1, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=187) with 1 segments in 21ms (91/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,446] INFO [LogLoader partition=_confluent_balancer_partition_samples-3, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,447] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-3, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=3, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (92/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,467] INFO [LogLoader partition=_confluent-telemetry-metrics-0, dir=/tmp/kafka-logs] Loading producer state till offset 629 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,468] INFO [LogLoader partition=_confluent-telemetry-metrics-0, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 629 (kafka.log.Log$)
+[2021-12-23 18:22:45,468] INFO [ProducerStateManager partition=_confluent-telemetry-metrics-0] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/_confluent-telemetry-metrics-0/00000000000000000629.snapshot,629)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:45,468] INFO [LogLoader partition=_confluent-telemetry-metrics-0, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 629 (kafka.log.Log$)
+[2021-12-23 18:22:45,468] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent-telemetry-metrics-0, topicId=EA3LM6xqTimFIekTgVXD2w, topic=_confluent-telemetry-metrics, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=629) with 1 segments in 21ms (93/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,489] INFO [LogLoader partition=_confluent_balancer_partition_samples-2, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,490] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-2, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=2, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (94/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,511] INFO [LogLoader partition=_confluent-telemetry-metrics-7, dir=/tmp/kafka-logs] Loading producer state till offset 341 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,511] INFO [LogLoader partition=_confluent-telemetry-metrics-7, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 341 (kafka.log.Log$)
+[2021-12-23 18:22:45,511] INFO [ProducerStateManager partition=_confluent-telemetry-metrics-7] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/_confluent-telemetry-metrics-7/00000000000000000341.snapshot,341)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:45,511] INFO [LogLoader partition=_confluent-telemetry-metrics-7, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 341 (kafka.log.Log$)
+[2021-12-23 18:22:45,512] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent-telemetry-metrics-7, topicId=EA3LM6xqTimFIekTgVXD2w, topic=_confluent-telemetry-metrics, partition=7, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=341) with 1 segments in 22ms (95/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,532] INFO [LogLoader partition=_confluent_balancer_partition_samples-5, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,532] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-5, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=5, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 20ms (96/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,554] INFO [LogLoader partition=_confluent-telemetry-metrics-9, dir=/tmp/kafka-logs] Loading producer state till offset 280 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,554] INFO [LogLoader partition=_confluent-telemetry-metrics-9, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 280 (kafka.log.Log$)
+[2021-12-23 18:22:45,554] INFO [ProducerStateManager partition=_confluent-telemetry-metrics-9] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/_confluent-telemetry-metrics-9/00000000000000000280.snapshot,280)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:45,554] INFO [LogLoader partition=_confluent-telemetry-metrics-9, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 280 (kafka.log.Log$)
+[2021-12-23 18:22:45,555] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent-telemetry-metrics-9, topicId=EA3LM6xqTimFIekTgVXD2w, topic=_confluent-telemetry-metrics, partition=9, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=280) with 1 segments in 22ms (97/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,575] INFO [LogLoader partition=_confluent-command-0, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,575] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent-command-0, topicId=_qgPUsPgTPmNRbmidt0VRw, topic=_confluent-command, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 20ms (98/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,595] INFO [LogLoader partition=quickstart-events-0, dir=/tmp/kafka-logs] Loading producer state till offset 3 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,617] INFO [ProducerStateManager partition=quickstart-events-0] Wrote producer snapshot at offset 3 with 0 producer ids in 21 ms. (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:45,618] INFO Completed load of Log(dir=/tmp/kafka-logs/quickstart-events-0, topicId=N_KuciQyQLWFnWq9SI6Jsg, topic=quickstart-events, partition=0, highWatermark=3, lastStableOffset=3, logStartOffset=3, logEndOffset=3) with 1 segments in 42ms (99/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,639] INFO [LogLoader partition=_confluent_balancer_broker_samples-6, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,640] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-6, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=6, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (100/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,661] INFO [LogLoader partition=_confluent_balancer_broker_samples-1, dir=/tmp/kafka-logs] Loading producer state till offset 1 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,661] INFO [LogLoader partition=_confluent_balancer_broker_samples-1, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 1 (kafka.log.Log$)
+[2021-12-23 18:22:45,661] INFO [ProducerStateManager partition=_confluent_balancer_broker_samples-1] Loading producer state from snapshot file 'SnapshotFile(/tmp/kafka-logs/_confluent_balancer_broker_samples-1/00000000000000000001.snapshot,1)' (kafka.log.ProducerStateManager)
+[2021-12-23 18:22:45,661] INFO [LogLoader partition=_confluent_balancer_broker_samples-1, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 1 (kafka.log.Log$)
+[2021-12-23 18:22:45,662] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-1, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=1, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=1) with 1 segments in 22ms (101/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,681] INFO [LogLoader partition=__consumer_offsets-45, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,682] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-45, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=45, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 20ms (102/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,703] INFO [LogLoader partition=_confluent_balancer_broker_samples-8, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,703] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-8, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=8, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (103/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,723] INFO [LogLoader partition=__consumer_offsets-42, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,724] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-42, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=42, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 20ms (104/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,745] INFO [LogLoader partition=_confluent_balancer_partition_samples-24, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,745] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-24, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=24, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (105/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,766] INFO [LogLoader partition=__consumer_offsets-29, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,766] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-29, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=29, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 20ms (106/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,787] INFO [LogLoader partition=__consumer_offsets-16, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,788] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-16, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=16, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (107/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,809] INFO [LogLoader partition=_confluent_balancer_partition_samples-23, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,810] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-23, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=23, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (108/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,831] INFO [LogLoader partition=__consumer_offsets-11, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,832] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-11, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=11, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (109/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,852] INFO [LogLoader partition=_confluent_balancer_partition_samples-15, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,852] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-15, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=15, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 20ms (110/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,873] INFO [LogLoader partition=__consumer_offsets-18, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,874] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-18, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=18, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (111/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,898] INFO [LogLoader partition=__consumer_offsets-27, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,898] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-27, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=27, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 24ms (112/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,919] INFO [LogLoader partition=_confluent_balancer_partition_samples-12, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,919] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-12, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=12, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (113/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,940] INFO [LogLoader partition=__consumer_offsets-20, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,941] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-20, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=20, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (114/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,962] INFO [LogLoader partition=__consumer_offsets-43, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,963] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-43, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=43, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (115/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:45,985] INFO [LogLoader partition=__consumer_offsets-44, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:45,985] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-44, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=44, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (116/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:46,006] INFO [LogLoader partition=_confluent_balancer_broker_samples-9, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:46,007] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-9, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=9, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (117/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:46,028] INFO [LogLoader partition=_confluent_balancer_broker_samples-0, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:46,029] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-0, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (118/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:46,049] INFO [LogLoader partition=_confluent_balancer_broker_samples-7, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:46,049] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_broker_samples-7, topicId=76xFBVDMSF2HRNhV0Evy5Q, topic=_confluent_balancer_broker_samples, partition=7, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (119/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:46,071] INFO [LogLoader partition=_confluent_balancer_partition_samples-13, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:46,071] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-13, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=13, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (120/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:46,092] INFO [LogLoader partition=__consumer_offsets-21, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:46,093] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-21, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=21, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (121/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:46,114] INFO [LogLoader partition=__consumer_offsets-19, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:46,114] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-19, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=19, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (122/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:46,135] INFO [LogLoader partition=_confluent_balancer_partition_samples-14, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:46,135] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-14, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=14, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (123/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:46,156] INFO [LogLoader partition=__consumer_offsets-26, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:46,157] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-26, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=26, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (124/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:46,178] INFO [LogLoader partition=_confluent_balancer_partition_samples-22, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:46,178] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-22, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=22, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (125/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:46,200] INFO [LogLoader partition=__consumer_offsets-10, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:46,200] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-10, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=10, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (126/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:46,221] INFO [LogLoader partition=__consumer_offsets-28, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:46,222] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-28, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=28, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (127/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:46,242] INFO [LogLoader partition=_confluent_balancer_partition_samples-25, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:46,242] INFO Completed load of Log(dir=/tmp/kafka-logs/_confluent_balancer_partition_samples-25, topicId=TLnizbezRHyYnsXJ4ahvog, topic=_confluent_balancer_partition_samples, partition=25, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 21ms (128/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:46,264] INFO [LogLoader partition=__consumer_offsets-17, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:22:46,264] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-17, topicId=cbqCXDbpQ5W1kitgS8a_ZQ, topic=__consumer_offsets, partition=17, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 22ms (129/129 loaded in /tmp/kafka-logs) (kafka.log.LogManager)
+[2021-12-23 18:22:46,265] INFO Loaded 129 logs in 2890ms. (kafka.log.LogManager)
+[2021-12-23 18:22:46,265] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager)
+[2021-12-23 18:22:46,266] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager)
+[2021-12-23 18:22:46,381] INFO [BrokerToControllerChannelManager broker=0 name=forwarding]: Starting (kafka.server.BrokerToControllerRequestThread)
+[2021-12-23 18:22:46,413] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas)
+[2021-12-23 18:22:46,416] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.Acceptor)
+[2021-12-23 18:22:46,428] INFO [SocketServer listenerType=ZK_BROKER, nodeId=0] Created data-plane acceptor and processors for endpoint : ListenerName(PLAINTEXT) (kafka.network.SocketServer)
+[2021-12-23 18:22:46,431] INFO [BrokerToControllerChannelManager broker=0 name=alterIsr]: Starting (kafka.server.BrokerToControllerRequestThread)
+[2021-12-23 18:22:46,440] INFO [ExpirationReaper-0-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2021-12-23 18:22:46,440] INFO [ExpirationReaper-0-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2021-12-23 18:22:46,440] INFO [ExpirationReaper-0-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2021-12-23 18:22:46,441] INFO [ExpirationReaper-0-ElectLeader]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2021-12-23 18:22:46,447] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler)
+[2021-12-23 18:22:46,471] INFO Creating /brokers/ids/0 (is it secure? false) (kafka.zk.KafkaZkClient)
+[2021-12-23 18:22:46,500] INFO Stat of the created znode at /brokers/ids/0 is: 436,436,1640301766477,1640301766477,1,0,0,72079179453431808,208,0,436
+ (kafka.zk.KafkaZkClient)
+[2021-12-23 18:22:46,501] INFO Registered broker 0 at path /brokers/ids/0 with addresses: PLAINTEXT://10.84.99.135:9092, czxid (broker epoch): 436 (kafka.zk.KafkaZkClient)
+[2021-12-23 18:22:46,545] INFO [ExpirationReaper-0-topic]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2021-12-23 18:22:46,548] INFO [ExpirationReaper-0-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2021-12-23 18:22:46,548] INFO [ExpirationReaper-0-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2021-12-23 18:22:46,554] INFO [GroupCoordinator 0]: Starting up. (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:46,570] INFO [GroupCoordinator 0]: Startup complete. (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:46,578] INFO [TransactionCoordinator id=0] Starting up. (kafka.coordinator.transaction.TransactionCoordinator)
+[2021-12-23 18:22:46,581] INFO [TransactionCoordinator id=0] Startup complete. (kafka.coordinator.transaction.TransactionCoordinator)
+[2021-12-23 18:22:46,581] INFO [Transaction Marker Channel Manager 0]: Starting (kafka.coordinator.transaction.TransactionMarkerChannelManager)
+[2021-12-23 18:22:46,596] INFO [ExpirationReaper-0-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2021-12-23 18:22:46,616] INFO [/config/changes-event-process-thread]: Starting (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread)
+[2021-12-23 18:22:46,618] INFO Processing notification(s) to /config/changes (kafka.common.ZkNodeChangeNotificationListener)
+[2021-12-23 18:22:46,621] INFO Processing override for entityPath: topics/_confluent_balancer_partition_samples with config: HashMap(cleanup.policy -> delete, retention.ms -> 3600000) (kafka.server.DynamicConfigManager)
+[2021-12-23 18:22:46,628] INFO Processing override for entityPath: topics/_confluent_balancer_broker_samples with config: HashMap(cleanup.policy -> delete, retention.ms -> 12000000) (kafka.server.DynamicConfigManager)
+[2021-12-23 18:22:46,631] INFO Processing override for entityPath: topics/_confluent_balancer_partition_samples with config: HashMap(cleanup.policy -> delete, retention.ms -> 3600000) (kafka.server.DynamicConfigManager)
+[2021-12-23 18:22:46,635] INFO Processing override for entityPath: topics/_confluent_balancer_broker_samples with config: HashMap(cleanup.policy -> delete, retention.ms -> 12000000) (kafka.server.DynamicConfigManager)
+[2021-12-23 18:22:46,637] INFO [SocketServer listenerType=ZK_BROKER, nodeId=0] Starting socket server acceptors and processors (kafka.network.SocketServer)
+[2021-12-23 18:22:46,637] INFO Processing override for entityPath: topics/_confluent_balancer_api_state with config: HashMap(cleanup.policy -> compact, retention.ms -> -1) (kafka.server.DynamicConfigManager)
+[2021-12-23 18:22:46,640] INFO [SocketServer listenerType=ZK_BROKER, nodeId=0] Started data-plane acceptor and processor(s) for endpoint : ListenerName(PLAINTEXT) (kafka.network.SocketServer)
+[2021-12-23 18:22:46,640] INFO [SocketServer listenerType=ZK_BROKER, nodeId=0] Started socket server acceptors and processors (kafka.network.SocketServer)
+[2021-12-23 18:22:46,640] INFO Processing override for entityPath: topics/_confluent_balancer_partition_samples with config: HashMap(cleanup.policy -> delete, retention.ms -> 3600000) (kafka.server.DynamicConfigManager)
+[2021-12-23 18:22:46,642] INFO Kafka version: 3.0.0 (org.apache.kafka.common.utils.AppInfoParser)
+[2021-12-23 18:22:46,642] INFO Kafka commitId: 8cb0a5e9d3441962 (org.apache.kafka.common.utils.AppInfoParser)
+[2021-12-23 18:22:46,642] INFO Kafka startTimeMs: 1640301766640 (org.apache.kafka.common.utils.AppInfoParser)
+[2021-12-23 18:22:46,644] INFO [KafkaServer id=0] started (kafka.server.KafkaServer)
+[2021-12-23 18:22:46,644] INFO Processing override for entityPath: topics/_confluent_balancer_broker_samples with config: HashMap(cleanup.policy -> delete, retention.ms -> 12000000) (kafka.server.DynamicConfigManager)
+[2021-12-23 18:22:46,649] INFO Processing override for entityPath: topics/_confluent_balancer_partition_samples with config: HashMap(cleanup.policy -> delete, retention.ms -> 3600000) (kafka.server.DynamicConfigManager)
+[2021-12-23 18:22:46,652] INFO Processing override for entityPath: topics/_confluent_balancer_broker_samples with config: HashMap(cleanup.policy -> delete, retention.ms -> 12000000) (kafka.server.DynamicConfigManager)
+[2021-12-23 18:22:46,687] INFO [BrokerToControllerChannelManager broker=0 name=forwarding]: Recorded new controller, from now on will use broker 10.84.99.135:9092 (id: 0 rack: null) (kafka.server.BrokerToControllerRequestThread)
+[2021-12-23 18:22:46,733] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions HashSet(_confluent-telemetry-metrics-10, _confluent_balancer_partition_samples-27, _confluent_balancer_broker_samples-16, _confluent-telemetry-metrics-6, _confluent-telemetry-metrics-9, _confluent_balancer_broker_samples-11, __consumer_offsets-22, _confluent_balancer_partition_samples-11, _confluent_balancer_broker_samples-24, __consumer_offsets-30, _confluent-telemetry-metrics-5, __consumer_offsets-8, __consumer_offsets-21, __consumer_offsets-4, __consumer_offsets-27, __consumer_offsets-7, _confluent_balancer_partition_samples-2, _confluent_balancer_broker_samples-21, __consumer_offsets-9, __consumer_offsets-46, _confluent_balancer_broker_samples-31, _confluent_balancer_partition_samples-18, _confluent_balancer_broker_samples-28, _confluent_balancer_broker_samples-17, quickstart-events-0, _confluent_balancer_partition_samples-8, _confluent_balancer_partition_samples-12, _confluent_balancer_partition_samples-28, _confluent_balancer_partition_samples-21, __consumer_offsets-25, _confluent_balancer_broker_samples-3, _confluent_balancer_partition_samples-24, _confluent_balancer_partition_samples-5, _confluent_balancer_partition_samples-17, _confluent_balancer_broker_samples-15, __consumer_offsets-35, __consumer_offsets-41, __consumer_offsets-23, __consumer_offsets-49, _confluent_balancer_partition_samples-13, __consumer_offsets-33, _confluent_balancer_broker_samples-30, _confluent_balancer_partition_samples-29, _confluent-telemetry-metrics-4, __consumer_offsets-47, __consumer_offsets-16, __consumer_offsets-28, _confluent_balancer_partition_samples-26, _confluent-telemetry-metrics-7, __consumer_offsets-31, __consumer_offsets-36, __consumer_offsets-42, _confluent_balancer_broker_samples-0, _confluent_balancer_partition_samples-10, _confluent_balancer_partition_samples-6, _confluent-telemetry-metrics-11, _confluent_balancer_broker_samples-25, __consumer_offsets-18, _confluent_balancer_partition_samples-22, __consumer_offsets-3, __consumer_offsets-37, _confluent_balancer_broker_samples-9, _confluent_balancer_broker_samples-13, _confluent-command-0, __consumer_offsets-15, __consumer_offsets-24, _confluent_balancer_partition_samples-25, _confluent_balancer_broker_samples-7, _confluent_balancer_partition_samples-1, _confluent_balancer_partition_samples-7, _confluent_balancer_broker_samples-20, _confluent_balancer_api_state-0, _confluent_balancer_broker_samples-29, _confluent-telemetry-metrics-8, __consumer_offsets-38, __consumer_offsets-17, _confluent_balancer_broker_samples-2, _confluent_balancer_partition_samples-30, __consumer_offsets-48, _confluent_balancer_broker_samples-22, _confluent_balancer_broker_samples-18, __consumer_offsets-19, _confluent-telemetry-metrics-3, _confluent_balancer_broker_samples-1, __consumer_offsets-11, _confluent_balancer_broker_samples-5, _confluent_balancer_partition_samples-14, _confluent_balancer_broker_samples-8, _confluent_balancer_partition_samples-31, _confluent_balancer_broker_samples-10, _confluent_balancer_broker_samples-14, __consumer_offsets-13, _confluent_balancer_broker_samples-19, __consumer_offsets-2, __consumer_offsets-43, __consumer_offsets-6, _confluent_balancer_partition_samples-9, __consumer_offsets-14, _confluent-telemetry-metrics-0, _confluent_balancer_broker_samples-12, _confluent_balancer_partition_samples-3, _confluent_balancer_broker_samples-27, __consumer_offsets-20, _confluent_balancer_broker_samples-6, __consumer_offsets-0, _confluent_balancer_broker_samples-26, __consumer_offsets-44, _confluent-telemetry-metrics-2, __consumer_offsets-39, __consumer_offsets-12, _confluent_balancer_partition_samples-19, _confluent_balancer_partition_samples-23, __consumer_offsets-45, __consumer_offsets-1, __consumer_offsets-5, __consumer_offsets-26, _confluent_balancer_broker_samples-4, __consumer_offsets-29, _confluent-telemetry-metrics-1, __consumer_offsets-34, _confluent_balancer_broker_samples-23, _confluent_balancer_partition_samples-15, __consumer_offsets-10, _confluent_balancer_partition_samples-0, _confluent_balancer_partition_samples-16, __consumer_offsets-32, __consumer_offsets-40, _confluent_balancer_partition_samples-20, _confluent_balancer_partition_samples-4) (kafka.server.ReplicaFetcherManager)
+[2021-12-23 18:22:46,734] INFO Processing notification(s) to /config/changes (kafka.common.ZkNodeChangeNotificationListener)
+[2021-12-23 18:22:46,735] INFO [BrokerToControllerChannelManager broker=0 name=alterIsr]: Recorded new controller, from now on will use broker 10.84.99.135:9092 (id: 0 rack: null) (kafka.server.BrokerToControllerRequestThread)
+[2021-12-23 18:22:46,741] INFO [Partition __consumer_offsets-3 broker=0] Log loaded for partition __consumer_offsets-3 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:46,762] INFO [Partition quickstart-events-0 broker=0] Log loaded for partition quickstart-events-0 with initial high watermark 3 (kafka.cluster.Partition)
+[2021-12-23 18:22:46,781] INFO [Partition __consumer_offsets-18 broker=0] Log loaded for partition __consumer_offsets-18 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:46,800] INFO [Partition _confluent_balancer_broker_samples-3 broker=0] Log loaded for partition _confluent_balancer_broker_samples-3 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:46,820] INFO [Partition _confluent-command-0 broker=0] Log loaded for partition _confluent-command-0 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:46,838] INFO [Partition _confluent_balancer_broker_samples-18 broker=0] Log loaded for partition _confluent_balancer_broker_samples-18 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:46,857] INFO [Partition _confluent_balancer_partition_samples-0 broker=0] Log loaded for partition _confluent_balancer_partition_samples-0 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:46,877] INFO [Partition _confluent_balancer_partition_samples-30 broker=0] Log loaded for partition _confluent_balancer_partition_samples-30 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:46,895] INFO [Partition __consumer_offsets-33 broker=0] Log loaded for partition __consumer_offsets-33 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:46,914] INFO [Partition _confluent_balancer_partition_samples-15 broker=0] Log loaded for partition _confluent_balancer_partition_samples-15 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:46,932] INFO [Partition __consumer_offsets-48 broker=0] Log loaded for partition __consumer_offsets-48 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:46,950] INFO [Partition __consumer_offsets-19 broker=0] Log loaded for partition __consumer_offsets-19 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:46,970] INFO [Partition __consumer_offsets-34 broker=0] Log loaded for partition __consumer_offsets-34 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:46,989] INFO [Partition __consumer_offsets-4 broker=0] Log loaded for partition __consumer_offsets-4 with initial high watermark 1 (kafka.cluster.Partition)
+[2021-12-23 18:22:46,990] INFO [Partition _confluent_balancer_broker_samples-17 broker=0] Log loaded for partition _confluent_balancer_broker_samples-17 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,008] INFO [Partition _confluent_balancer_broker_samples-2 broker=0] Log loaded for partition _confluent_balancer_broker_samples-2 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,027] INFO [Partition _confluent_balancer_partition_samples-16 broker=0] Log loaded for partition _confluent_balancer_partition_samples-16 with initial high watermark 129 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,028] INFO [Partition _confluent_balancer_partition_samples-1 broker=0] Log loaded for partition _confluent_balancer_partition_samples-1 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,046] INFO [Partition __consumer_offsets-49 broker=0] Log loaded for partition __consumer_offsets-49 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,065] INFO [Partition _confluent_balancer_partition_samples-31 broker=0] Log loaded for partition _confluent_balancer_partition_samples-31 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,084] INFO [Partition _confluent-telemetry-metrics-11 broker=0] Log loaded for partition _confluent-telemetry-metrics-11 with initial high watermark 326 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,085] INFO [Partition _confluent_balancer_broker_samples-20 broker=0] Log loaded for partition _confluent_balancer_broker_samples-20 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,104] INFO [Partition _confluent_balancer_partition_samples-2 broker=0] Log loaded for partition _confluent_balancer_partition_samples-2 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,124] INFO [Partition __consumer_offsets-31 broker=0] Log loaded for partition __consumer_offsets-31 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,143] INFO [Partition _confluent_balancer_partition_samples-17 broker=0] Log loaded for partition _confluent_balancer_partition_samples-17 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,163] INFO [Partition __consumer_offsets-46 broker=0] Log loaded for partition __consumer_offsets-46 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,183] INFO [Partition __consumer_offsets-1 broker=0] Log loaded for partition __consumer_offsets-1 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,203] INFO [Partition __consumer_offsets-16 broker=0] Log loaded for partition __consumer_offsets-16 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,222] INFO [Partition __consumer_offsets-2 broker=0] Log loaded for partition __consumer_offsets-2 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,241] INFO [Partition _confluent_balancer_api_state-0 broker=0] Log loaded for partition _confluent_balancer_api_state-0 with initial high watermark 1 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,241] INFO [Partition _confluent-telemetry-metrics-10 broker=0] Log loaded for partition _confluent-telemetry-metrics-10 with initial high watermark 375 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,241] INFO [Partition _confluent_balancer_broker_samples-19 broker=0] Log loaded for partition _confluent_balancer_broker_samples-19 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,261] INFO [Partition _confluent_balancer_broker_samples-4 broker=0] Log loaded for partition _confluent_balancer_broker_samples-4 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,281] INFO [Partition _confluent_balancer_partition_samples-18 broker=0] Log loaded for partition _confluent_balancer_partition_samples-18 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,301] INFO [Partition _confluent_balancer_partition_samples-3 broker=0] Log loaded for partition _confluent_balancer_partition_samples-3 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,319] INFO [Partition __consumer_offsets-47 broker=0] Log loaded for partition __consumer_offsets-47 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,339] INFO [Partition __consumer_offsets-17 broker=0] Log loaded for partition __consumer_offsets-17 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,359] INFO [Partition __consumer_offsets-32 broker=0] Log loaded for partition __consumer_offsets-32 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,378] INFO [Partition __consumer_offsets-37 broker=0] Log loaded for partition __consumer_offsets-37 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,399] INFO [Partition __consumer_offsets-7 broker=0] Log loaded for partition __consumer_offsets-7 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,419] INFO [Partition __consumer_offsets-22 broker=0] Log loaded for partition __consumer_offsets-22 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,439] INFO [Partition _confluent-telemetry-metrics-9 broker=0] Log loaded for partition _confluent-telemetry-metrics-9 with initial high watermark 280 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,439] INFO [Partition _confluent_balancer_broker_samples-21 broker=0] Log loaded for partition _confluent_balancer_broker_samples-21 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,459] INFO [Partition _confluent_balancer_broker_samples-6 broker=0] Log loaded for partition _confluent_balancer_broker_samples-6 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,479] INFO [Partition _confluent_balancer_partition_samples-4 broker=0] Log loaded for partition _confluent_balancer_partition_samples-4 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,498] INFO [Partition _confluent_balancer_partition_samples-19 broker=0] Log loaded for partition _confluent_balancer_partition_samples-19 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,519] INFO [Partition __consumer_offsets-23 broker=0] Log loaded for partition __consumer_offsets-23 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,538] INFO [Partition __consumer_offsets-38 broker=0] Log loaded for partition __consumer_offsets-38 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,559] INFO [Partition _confluent_balancer_broker_samples-5 broker=0] Log loaded for partition _confluent_balancer_broker_samples-5 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,578] INFO [Partition _confluent-telemetry-metrics-8 broker=0] Log loaded for partition _confluent-telemetry-metrics-8 with initial high watermark 661 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,578] INFO [Partition __consumer_offsets-8 broker=0] Log loaded for partition __consumer_offsets-8 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,597] INFO [Partition _confluent_balancer_partition_samples-20 broker=0] Log loaded for partition _confluent_balancer_partition_samples-20 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,616] INFO [Partition _confluent_balancer_partition_samples-5 broker=0] Log loaded for partition _confluent_balancer_partition_samples-5 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,636] INFO [Partition __consumer_offsets-35 broker=0] Log loaded for partition __consumer_offsets-35 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,656] INFO [Partition __consumer_offsets-5 broker=0] Log loaded for partition __consumer_offsets-5 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,675] INFO [Partition __consumer_offsets-20 broker=0] Log loaded for partition __consumer_offsets-20 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,696] INFO [Partition _confluent_balancer_broker_samples-23 broker=0] Log loaded for partition _confluent_balancer_broker_samples-23 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,716] INFO [Partition _confluent_balancer_broker_samples-8 broker=0] Log loaded for partition _confluent_balancer_broker_samples-8 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,734] INFO [Partition _confluent-telemetry-metrics-7 broker=0] Log loaded for partition _confluent-telemetry-metrics-7 with initial high watermark 341 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,735] INFO [Partition _confluent_balancer_partition_samples-21 broker=0] Log loaded for partition _confluent_balancer_partition_samples-21 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,753] INFO [Partition __consumer_offsets-21 broker=0] Log loaded for partition __consumer_offsets-21 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,772] INFO [Partition __consumer_offsets-36 broker=0] Log loaded for partition __consumer_offsets-36 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,792] INFO [Partition _confluent_balancer_broker_samples-7 broker=0] Log loaded for partition _confluent_balancer_broker_samples-7 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,811] INFO [Partition __consumer_offsets-6 broker=0] Log loaded for partition __consumer_offsets-6 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,831] INFO [Partition _confluent_balancer_partition_samples-6 broker=0] Log loaded for partition _confluent_balancer_partition_samples-6 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,866] INFO [Partition _confluent_balancer_broker_samples-22 broker=0] Log loaded for partition _confluent_balancer_broker_samples-22 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,885] INFO [Partition _confluent-telemetry-metrics-6 broker=0] Log loaded for partition _confluent-telemetry-metrics-6 with initial high watermark 227 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,886] INFO [Partition _confluent_balancer_broker_samples-25 broker=0] Log loaded for partition _confluent_balancer_broker_samples-25 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,905] INFO [Partition _confluent_balancer_broker_samples-10 broker=0] Log loaded for partition _confluent_balancer_broker_samples-10 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,926] INFO [Partition _confluent_balancer_partition_samples-22 broker=0] Log loaded for partition _confluent_balancer_partition_samples-22 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,945] INFO [Partition __consumer_offsets-41 broker=0] Log loaded for partition __consumer_offsets-41 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,966] INFO [Partition _confluent_balancer_partition_samples-7 broker=0] Log loaded for partition _confluent_balancer_partition_samples-7 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:47,985] INFO [Partition __consumer_offsets-10 broker=0] Log loaded for partition __consumer_offsets-10 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,005] INFO [Partition _confluent-telemetry-metrics-5 broker=0] Log loaded for partition _confluent-telemetry-metrics-5 with initial high watermark 419 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,006] INFO [Partition _confluent_balancer_broker_samples-9 broker=0] Log loaded for partition _confluent_balancer_broker_samples-9 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,025] INFO [Partition _confluent_balancer_partition_samples-8 broker=0] Log loaded for partition _confluent_balancer_partition_samples-8 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,044] INFO [Partition _confluent_balancer_broker_samples-24 broker=0] Log loaded for partition _confluent_balancer_broker_samples-24 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,063] INFO [Partition _confluent_balancer_partition_samples-23 broker=0] Log loaded for partition _confluent_balancer_partition_samples-23 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,083] INFO [Partition __consumer_offsets-11 broker=0] Log loaded for partition __consumer_offsets-11 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,102] INFO [Partition __consumer_offsets-26 broker=0] Log loaded for partition __consumer_offsets-26 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,123] INFO [Partition _confluent-telemetry-metrics-4 broker=0] Log loaded for partition _confluent-telemetry-metrics-4 with initial high watermark 447 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,123] INFO [Partition _confluent_balancer_broker_samples-27 broker=0] Log loaded for partition _confluent_balancer_broker_samples-27 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,142] INFO [Partition _confluent_balancer_broker_samples-12 broker=0] Log loaded for partition _confluent_balancer_broker_samples-12 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,162] INFO [Partition _confluent_balancer_partition_samples-24 broker=0] Log loaded for partition _confluent_balancer_partition_samples-24 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,181] INFO [Partition __consumer_offsets-39 broker=0] Log loaded for partition __consumer_offsets-39 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,201] INFO [Partition _confluent_balancer_partition_samples-9 broker=0] Log loaded for partition _confluent_balancer_partition_samples-9 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,220] INFO [Partition __consumer_offsets-9 broker=0] Log loaded for partition __consumer_offsets-9 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,240] INFO [Partition __consumer_offsets-24 broker=0] Log loaded for partition __consumer_offsets-24 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,261] INFO [Partition _confluent-telemetry-metrics-3 broker=0] Log loaded for partition _confluent-telemetry-metrics-3 with initial high watermark 735 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,261] INFO [Partition _confluent_balancer_broker_samples-11 broker=0] Log loaded for partition _confluent_balancer_broker_samples-11 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,280] INFO [Partition _confluent_balancer_partition_samples-10 broker=0] Log loaded for partition _confluent_balancer_partition_samples-10 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,299] INFO [Partition _confluent_balancer_broker_samples-26 broker=0] Log loaded for partition _confluent_balancer_broker_samples-26 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,319] INFO [Partition _confluent_balancer_partition_samples-25 broker=0] Log loaded for partition _confluent_balancer_partition_samples-25 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,338] INFO [Partition __consumer_offsets-25 broker=0] Log loaded for partition __consumer_offsets-25 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,358] INFO [Partition __consumer_offsets-40 broker=0] Log loaded for partition __consumer_offsets-40 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,377] INFO [Partition _confluent-telemetry-metrics-2 broker=0] Log loaded for partition _confluent-telemetry-metrics-2 with initial high watermark 197 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,377] INFO [Partition _confluent_balancer_partition_samples-26 broker=0] Log loaded for partition _confluent_balancer_partition_samples-26 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,396] INFO [Partition _confluent_balancer_partition_samples-11 broker=0] Log loaded for partition _confluent_balancer_partition_samples-11 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,416] INFO [Partition __consumer_offsets-29 broker=0] Log loaded for partition __consumer_offsets-29 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,435] INFO [Partition __consumer_offsets-44 broker=0] Log loaded for partition __consumer_offsets-44 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,454] INFO [Partition __consumer_offsets-14 broker=0] Log loaded for partition __consumer_offsets-14 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,473] INFO [Partition _confluent-telemetry-metrics-1 broker=0] Log loaded for partition _confluent-telemetry-metrics-1 with initial high watermark 187 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,473] INFO [Partition _confluent_balancer_broker_samples-29 broker=0] Log loaded for partition _confluent_balancer_broker_samples-29 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,493] INFO [Partition _confluent_balancer_broker_samples-14 broker=0] Log loaded for partition _confluent_balancer_broker_samples-14 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,512] INFO [Partition _confluent_balancer_partition_samples-12 broker=0] Log loaded for partition _confluent_balancer_partition_samples-12 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,531] INFO [Partition _confluent_balancer_broker_samples-28 broker=0] Log loaded for partition _confluent_balancer_broker_samples-28 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,551] INFO [Partition _confluent_balancer_partition_samples-27 broker=0] Log loaded for partition _confluent_balancer_partition_samples-27 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,570] INFO [Partition __consumer_offsets-45 broker=0] Log loaded for partition __consumer_offsets-45 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,590] INFO [Partition __consumer_offsets-15 broker=0] Log loaded for partition __consumer_offsets-15 with initial high watermark 2 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,590] INFO [Partition __consumer_offsets-30 broker=0] Log loaded for partition __consumer_offsets-30 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,610] INFO [Partition _confluent_balancer_broker_samples-13 broker=0] Log loaded for partition _confluent_balancer_broker_samples-13 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,630] INFO [Partition _confluent-telemetry-metrics-0 broker=0] Log loaded for partition _confluent-telemetry-metrics-0 with initial high watermark 629 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,630] INFO [Partition __consumer_offsets-0 broker=0] Log loaded for partition __consumer_offsets-0 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,648] INFO [Partition _confluent_balancer_partition_samples-28 broker=0] Log loaded for partition _confluent_balancer_partition_samples-28 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,668] INFO [Partition _confluent_balancer_partition_samples-13 broker=0] Log loaded for partition _confluent_balancer_partition_samples-13 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,688] INFO [Partition __consumer_offsets-27 broker=0] Log loaded for partition __consumer_offsets-27 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,707] INFO [Partition __consumer_offsets-42 broker=0] Log loaded for partition __consumer_offsets-42 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,726] INFO [Partition _confluent_balancer_broker_samples-1 broker=0] Log loaded for partition _confluent_balancer_broker_samples-1 with initial high watermark 1 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,727] INFO [Partition __consumer_offsets-12 broker=0] Log loaded for partition __consumer_offsets-12 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,747] INFO [Partition _confluent_balancer_broker_samples-31 broker=0] Log loaded for partition _confluent_balancer_broker_samples-31 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,766] INFO [Partition _confluent_balancer_broker_samples-16 broker=0] Log loaded for partition _confluent_balancer_broker_samples-16 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,787] INFO [Partition _confluent_balancer_partition_samples-29 broker=0] Log loaded for partition _confluent_balancer_partition_samples-29 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,806] INFO [Partition __consumer_offsets-43 broker=0] Log loaded for partition __consumer_offsets-43 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,824] INFO [Partition __consumer_offsets-13 broker=0] Log loaded for partition __consumer_offsets-13 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,844] INFO [Partition __consumer_offsets-28 broker=0] Log loaded for partition __consumer_offsets-28 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,863] INFO [Partition _confluent_balancer_broker_samples-15 broker=0] Log loaded for partition _confluent_balancer_broker_samples-15 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,883] INFO [Partition _confluent_balancer_broker_samples-0 broker=0] Log loaded for partition _confluent_balancer_broker_samples-0 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,903] INFO [Partition _confluent_balancer_partition_samples-14 broker=0] Log loaded for partition _confluent_balancer_partition_samples-14 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,923] INFO [Partition _confluent_balancer_broker_samples-30 broker=0] Log loaded for partition _confluent_balancer_broker_samples-30 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:22:48,947] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 3 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,948] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-3 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,949] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 18 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,949] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-18 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,949] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 33 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,949] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-33 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,949] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 48 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,949] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-48 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,949] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 19 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,949] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-19 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,949] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 34 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,949] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-34 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,949] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 4 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,949] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-4 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,949] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 49 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,949] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-49 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,949] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 31 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,949] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-31 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,950] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 46 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,950] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-46 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,950] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 1 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,950] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-1 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,950] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 16 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,950] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-16 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,950] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 2 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,950] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-2 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,950] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 47 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,950] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-47 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,950] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 17 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,950] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-17 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,950] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 32 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,950] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-32 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,950] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 37 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,950] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-37 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,950] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 7 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,950] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-7 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,950] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 22 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,950] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-22 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,950] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 23 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,951] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-23 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,951] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 38 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,951] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-38 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,953] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-3 in 4 milliseconds for epoch 0, of which 2 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,967] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 8 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,968] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-8 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,968] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 35 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,968] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-35 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,968] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-18 in 19 milliseconds for epoch 0, of which 19 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,968] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 5 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,968] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-5 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,968] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 20 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,968] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-20 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,968] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-33 in 19 milliseconds for epoch 0, of which 19 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,968] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 21 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,968] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-21 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,968] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-48 in 19 milliseconds for epoch 0, of which 19 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,968] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 36 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,968] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-36 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,968] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-19 in 19 milliseconds for epoch 0, of which 19 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,968] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 6 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,968] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-6 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,968] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-34 in 19 milliseconds for epoch 0, of which 19 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,968] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 41 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,968] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-41 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,968] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 10 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-10 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 11 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-11 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 26 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-26 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 39 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-39 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 9 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-9 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 24 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-24 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 25 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-25 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 40 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-40 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 29 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-29 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 44 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-44 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 14 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-14 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 45 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-45 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 15 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-15 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 30 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-30 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 0 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-0 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 27 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,969] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-27 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,969] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 42 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,970] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-42 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,970] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 12 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,970] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-12 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,970] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 43 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,970] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-43 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,970] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 13 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,970] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-13 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,970] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 28 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,970] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-28 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,984] INFO Loaded member MemberMetadata(memberId=kafka-cruise-control-873536e5-38a0-4bc4-b525-d795ea3e3452, groupInstanceId=None, clientId=kafka-cruise-control, clientHost=/10.84.99.135, sessionTimeoutMs=45000, rebalanceTimeoutMs=2147483647, supportedProtocols=List(range)) in group ConfluentTelemetryReporterSampler--4530682266446274160 with generation 1. (kafka.coordinator.group.GroupMetadata$)
+[2021-12-23 18:22:48,987] INFO [GroupCoordinator 0]: Loading group metadata for ConfluentTelemetryReporterSampler--4530682266446274160 with generation 1 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,989] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-4 in 40 milliseconds for epoch 0, of which 19 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,989] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-49 in 40 milliseconds for epoch 0, of which 40 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,989] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-31 in 39 milliseconds for epoch 0, of which 39 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,989] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-46 in 39 milliseconds for epoch 0, of which 39 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,989] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-1 in 39 milliseconds for epoch 0, of which 39 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,990] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-16 in 40 milliseconds for epoch 0, of which 39 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,990] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-2 in 40 milliseconds for epoch 0, of which 40 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,990] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-47 in 40 milliseconds for epoch 0, of which 40 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,990] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-17 in 40 milliseconds for epoch 0, of which 40 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,990] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-32 in 40 milliseconds for epoch 0, of which 40 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,990] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-37 in 40 milliseconds for epoch 0, of which 40 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,990] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-7 in 40 milliseconds for epoch 0, of which 40 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,990] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-22 in 40 milliseconds for epoch 0, of which 40 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,990] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-23 in 39 milliseconds for epoch 0, of which 39 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,990] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-38 in 23 milliseconds for epoch 0, of which 23 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,990] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-8 in 22 milliseconds for epoch 0, of which 22 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,990] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-35 in 22 milliseconds for epoch 0, of which 22 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,990] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-5 in 22 milliseconds for epoch 0, of which 22 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,991] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-20 in 23 milliseconds for epoch 0, of which 23 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,991] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-21 in 23 milliseconds for epoch 0, of which 23 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,991] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-36 in 23 milliseconds for epoch 0, of which 23 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,991] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-6 in 23 milliseconds for epoch 0, of which 23 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,991] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-41 in 23 milliseconds for epoch 0, of which 23 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,991] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-10 in 22 milliseconds for epoch 0, of which 22 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,991] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-11 in 22 milliseconds for epoch 0, of which 22 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,991] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-26 in 22 milliseconds for epoch 0, of which 22 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,991] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-39 in 22 milliseconds for epoch 0, of which 22 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,991] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-9 in 22 milliseconds for epoch 0, of which 22 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,991] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-24 in 22 milliseconds for epoch 0, of which 22 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,991] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-25 in 22 milliseconds for epoch 0, of which 22 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,991] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-40 in 22 milliseconds for epoch 0, of which 22 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,992] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-29 in 23 milliseconds for epoch 0, of which 23 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,992] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-44 in 23 milliseconds for epoch 0, of which 23 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,992] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-14 in 23 milliseconds for epoch 0, of which 23 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,992] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-45 in 23 milliseconds for epoch 0, of which 23 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,993] INFO Loaded member MemberMetadata(memberId=consumer-console-consumer-24071-1-8df92226-5cfc-4b07-90f6-61a27cf30dad, groupInstanceId=None, clientId=consumer-console-consumer-24071-1, clientHost=/10.84.99.135, sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, supportedProtocols=List(range)) in group console-consumer-24071 with generation 1. (kafka.coordinator.group.GroupMetadata$)
+[2021-12-23 18:22:48,993] INFO [GroupCoordinator 0]: Loading group metadata for console-consumer-24071 with generation 2 (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:22:48,993] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-15 in 24 milliseconds for epoch 0, of which 23 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,993] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-30 in 24 milliseconds for epoch 0, of which 24 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,993] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-0 in 24 milliseconds for epoch 0, of which 24 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,993] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-27 in 24 milliseconds for epoch 0, of which 24 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,993] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-42 in 23 milliseconds for epoch 0, of which 23 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,993] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-12 in 23 milliseconds for epoch 0, of which 23 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,993] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-43 in 23 milliseconds for epoch 0, of which 23 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,994] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-13 in 24 milliseconds for epoch 0, of which 24 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:22:48,994] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-28 in 24 milliseconds for epoch 0, of which 24 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:23:26,385] INFO Creating topic twitterdata with configuration {} and initial partition assignment HashMap(0 -> ArrayBuffer(0), 1 -> ArrayBuffer(0)) (kafka.zk.AdminZkClient)
+[2021-12-23 18:23:26,509] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(twitterdata-0, twitterdata-1) (kafka.server.ReplicaFetcherManager)
+[2021-12-23 18:23:26,513] INFO [LogLoader partition=twitterdata-0, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:23:26,514] INFO Created log for partition twitterdata-0 in /tmp/kafka-logs/twitterdata-0 with properties {} (kafka.log.LogManager)
+[2021-12-23 18:23:26,514] INFO [Partition twitterdata-0 broker=0] No checkpointed highwatermark is found for partition twitterdata-0 (kafka.cluster.Partition)
+[2021-12-23 18:23:26,514] INFO [Partition twitterdata-0 broker=0] Log loaded for partition twitterdata-0 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:23:26,552] INFO [LogLoader partition=twitterdata-1, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
+[2021-12-23 18:23:26,552] INFO Created log for partition twitterdata-1 in /tmp/kafka-logs/twitterdata-1 with properties {} (kafka.log.LogManager)
+[2021-12-23 18:23:26,552] INFO [Partition twitterdata-1 broker=0] No checkpointed highwatermark is found for partition twitterdata-1 (kafka.cluster.Partition)
+[2021-12-23 18:23:26,552] INFO [Partition twitterdata-1 broker=0] Log loaded for partition twitterdata-1 with initial high watermark 0 (kafka.cluster.Partition)
+[2021-12-23 18:23:33,993] INFO [GroupCoordinator 0]: Member kafka-cruise-control-873536e5-38a0-4bc4-b525-d795ea3e3452 in group ConfluentTelemetryReporterSampler--4530682266446274160 has failed, removing it from the group (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:23:33,999] INFO [GroupCoordinator 0]: Preparing to rebalance group ConfluentTelemetryReporterSampler--4530682266446274160 in state PreparingRebalance with old generation 1 (__consumer_offsets-4) (reason: removing member kafka-cruise-control-873536e5-38a0-4bc4-b525-d795ea3e3452 on heartbeat expiration) (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:23:34,001] INFO [GroupCoordinator 0]: Group ConfluentTelemetryReporterSampler--4530682266446274160 with generation 2 is now empty (__consumer_offsets-4) (kafka.coordinator.group.GroupCoordinator)
+[2021-12-23 18:32:46,552] INFO [GroupMetadataManager brokerId=0] Group console-consumer-24071 transitioned to Dead in generation 2 (kafka.coordinator.group.GroupMetadataManager)
+[2021-12-23 18:32:46,561] INFO [GroupMetadataManager brokerId=0] Group ConfluentTelemetryReporterSampler--4530682266446274160 transitioned to Dead in generation 2 (kafka.coordinator.group.GroupMetadataManager)
diff --git a/producer.py b/producer.py
index e677082..6723ae0 100644
--- a/producer.py
+++ b/producer.py
@@ -2,7 +2,7 @@ from dotenv import load_dotenv
 from tweepy.streaming import StreamListener
 from tweepy import OAuthHandler
 from tweepy import Stream
-from kafka import KafkaProducer, producer
+from kafka import KafkaProducer
 import os
 
 load_dotenv()
@@ -16,7 +16,7 @@ producer = KafkaProducer(bootstrap_servers='localhost:9092')
 
 topic_name = 'twitterdata'
 
-class TwitterAuth():
+class twitterAuth():
     """Set up Twitter Authentication"""
     def authenticateTwitterApp(self):
         auth = OAuthHandler(consumer_key, consumer_secret)
@@ -25,6 +25,9 @@ class TwitterAuth():
 
 class TwitterStreamer():
     """Set up Streamer"""
+    def __init__(self):
+        self.twitterAuth = twitterAuth()
+
     def stream_tweets(self):
         while True:
             listener = ListenerTS()
diff --git a/requirements.txt b/requirements.txt
index 6a87040..ce2b409 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -1,3 +1,4 @@
-kafka
+kafka-python
 dotenv
-tweepy
+tweepy==3.9.0
+pyspark