[2021-02-17 02:24:52,392] INFO [Partition __consumer_offsets-0 broker=1] Log loaded for partition __consumer_offsets-0 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,392] INFO [Broker id=1] Leader __consumer_offsets-0 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,392] INFO [Partition _confluent_balancer_partition_samples-28 broker=1] Log loaded for partition _confluent_balancer_partition_samples-28 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,392] INFO [Broker id=1] Leader _confluent_balancer_partition_samples-28 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,393] INFO [Partition _confluent_balancer_partition_samples-13 broker=1] Log loaded for partition _confluent_balancer_partition_samples-13 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,393] INFO [Broker id=1] Leader _confluent_balancer_partition_samples-13 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,393] INFO [Partition _confluent-metrics-11 broker=1] Log loaded for partition _confluent-metrics-11 with initial high watermark 3 (kafka.cluster.Partition) [2021-02-17 02:24:52,393] INFO [Broker id=1] Leader _confluent-metrics-11 starts at leader epoch 0 from offset 3 with high watermark 3 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,394] INFO [Partition __consumer_offsets-27 broker=1] Log loaded for partition __consumer_offsets-27 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,394] INFO [Broker id=1] Leader __consumer_offsets-27 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,394] INFO [Partition __consumer_offsets-42 broker=1] Log loaded for partition __consumer_offsets-42 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,394] INFO [Broker id=1] Leader __consumer_offsets-42 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,395] INFO [Partition _confluent_balancer_broker_samples-1 broker=1] Log loaded for partition _confluent_balancer_broker_samples-1 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,395] INFO [Broker id=1] Leader _confluent_balancer_broker_samples-1 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,395] INFO [Partition __consumer_offsets-12 broker=1] Log loaded for partition __consumer_offsets-12 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,395] INFO [Broker id=1] Leader __consumer_offsets-12 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,395] INFO [Partition _confluent_balancer_broker_samples-31 broker=1] Log loaded for partition _confluent_balancer_broker_samples-31 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,395] INFO [Broker id=1] Leader _confluent_balancer_broker_samples-31 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,396] INFO [Partition _confluent_balancer_broker_samples-16 broker=1] Log loaded for partition _confluent_balancer_broker_samples-16 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,396] INFO [Broker id=1] Leader _confluent_balancer_broker_samples-16 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,396] INFO [Partition _confluent_balancer_partition_samples-29 broker=1] Log loaded for partition _confluent_balancer_partition_samples-29 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,396] INFO [Broker id=1] Leader _confluent_balancer_partition_samples-29 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,396] INFO [Partition __consumer_offsets-43 broker=1] Log loaded for partition __consumer_offsets-43 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,396] INFO [Broker id=1] Leader __consumer_offsets-43 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,396] INFO [Partition __consumer_offsets-13 broker=1] Log loaded for partition __consumer_offsets-13 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,397] INFO [Broker id=1] Leader __consumer_offsets-13 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,397] INFO [Partition __consumer_offsets-28 broker=1] Log loaded for partition __consumer_offsets-28 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,397] INFO [Broker id=1] Leader __consumer_offsets-28 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,397] INFO [Partition _confluent_balancer_broker_samples-15 broker=1] Log loaded for partition _confluent_balancer_broker_samples-15 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,397] INFO [Broker id=1] Leader _confluent_balancer_broker_samples-15 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,439] INFO [Partition _confluent_balancer_broker_samples-0 broker=1] Log loaded for partition _confluent_balancer_broker_samples-0 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,440] INFO [Broker id=1] Leader _confluent_balancer_broker_samples-0 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,440] INFO [Partition _confluent_balancer_partition_samples-14 broker=1] Log loaded for partition _confluent_balancer_partition_samples-14 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,441] INFO [Broker id=1] Leader _confluent_balancer_partition_samples-14 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,441] INFO [Partition _confluent_balancer_broker_samples-30 broker=1] Log loaded for partition _confluent_balancer_broker_samples-30 with initial high watermark 0 (kafka.cluster.Partition) [2021-02-17 02:24:52,452] INFO [Broker id=1] Leader _confluent_balancer_broker_samples-30 starts at leader epoch 0 from offset 0 with high watermark 0 ISR 1 observers addingReplicas removingReplicas .Previous leader epoch was -1. (state.change.logger) [2021-02-17 02:24:52,531] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-3 (state.change.logger) [2021-02-17 02:24:52,531] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-18 (state.change.logger) [2021-02-17 02:24:52,531] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _schemas-0 (state.change.logger) [2021-02-17 02:24:52,532] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-3 (state.change.logger) [2021-02-17 02:24:52,532] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-18 (state.change.logger) [2021-02-17 02:24:52,532] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-0 (state.change.logger) [2021-02-17 02:24:52,532] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-30 (state.change.logger) [2021-02-17 02:24:52,532] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-33 (state.change.logger) [2021-02-17 02:24:52,533] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-15 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-48 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-19 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-34 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-4 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-17 (st ate.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-2 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-16 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-1 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-49 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-31 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-20 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-2 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-31 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-17 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-46 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-1 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-16 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-2 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-19 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-4 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-18 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-3 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-47 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent-metrics-0 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-17 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-32 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-37 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-7 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-22 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-21 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-6 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-4 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-19 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent-metrics-1 (state.change.logger) [2021-02-17 02:24:52,544] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-23 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-38 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-5 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-8 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-20 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-5 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent-metrics-2 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-35 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-5 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-20 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-23 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-8 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-21 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent-metrics-3 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent-metrics-4 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-21 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-36 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-7 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-6 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-6 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-22 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent-metrics-5 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-25 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-10 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-22 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-41 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-7 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-10 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-9 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent-metrics-6 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-8 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-24 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-23 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-11 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-26 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-27 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-12 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent-metrics-7 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-24 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-39 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-9 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-9 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-24 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-11 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-10 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-26 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-25 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent-metrics-8 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-25 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-40 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-26 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-11 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent-metrics-9 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-29 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-44 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-14 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-29 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-14 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-12 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-28 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-27 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent-metrics-10 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-45 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-15 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-30 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-13 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-0 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-28 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-13 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent-metrics-11 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-27 (state.change.logger) [2021-02-17 02:24:52,545] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-42 (state.change.logger) [2021-02-17 02:24:52,546] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-1 (state.change.logger) [2021-02-17 02:24:52,546] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-12 (state.change.logger) [2021-02-17 02:24:52,546] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-31 (state.change.logger) [2021-02-17 02:24:52,546] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-16 (state.change.logger) [2021-02-17 02:24:52,546] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-29 (state.change.logger) [2021-02-17 02:24:52,546] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-43 (state.change.logger) [2021-02-17 02:24:52,546] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-13 (state.change.logger) [2021-02-17 02:24:52,546] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition __consumer_offsets-28 (state.change.logger) [2021-02-17 02:24:52,546] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-15 (state.change.logger) [2021-02-17 02:24:52,546] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-0 (state.change.logger) [2021-02-17 02:24:52,546] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_partition_samples-14 (state.change.logger) [2021-02-17 02:24:52,546] TRACE [Broker id=1] Completed LeaderAndIsr request correlationId 1 from controller 1 epoch 4 for the become-leader transition for partition _confluent_balancer_broker_samples-30 (state.change.logger) [2021-02-17 02:24:52,699] WARN [ReplicaManager broker=1] Found stray partitions (kafka.server.ReplicaManager) [2021-02-17 02:24:52,718] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-3 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,798] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-18 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,799] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-33 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,799] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-48 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,799] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-19 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,799] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-34 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,800] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-4 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,800] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-49 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,800] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-31 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,800] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-46 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,801] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-1 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,801] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-16 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,801] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-2 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,801] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-47 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,802] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-17 (kafka.coordinator.group.GroupMetadata Manager) [2021-02-17 02:24:52,802] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-32 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,803] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-37 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,803] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-7 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,818] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-22 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,819] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-23 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,823] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-38 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,824] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-8 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,824] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-35 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,824] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-5 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,825] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-20 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,825] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-21 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,825] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-36 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,830] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-6 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,830] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-41 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,838] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-10 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,839] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-11 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,839] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-26 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,839] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-39 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,840] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-9 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,840] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-24 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,840] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-25 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,841] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-40 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,841] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-29 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,848] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-44 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,849] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-14 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,849] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-45 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,849] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-15 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,850] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-30 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,850] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-0 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,850] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-27 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,851] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-42 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,858] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-12 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,859] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-43 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,859] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-13 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,859] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-28 (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,843] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-3 in 124 milliseconds, of which 106 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,871] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-18 in 73 milliseconds, of which 72 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,871] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-33 in 72 milliseconds, of which 72 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,871] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-48 in 72 milliseconds, of which 72 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,871] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-19 in 72 milliseconds, of which 72 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,871] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-34 in 71 milliseconds, of which 71 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,872] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-4 in 72 milliseconds, of which 72 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,872] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-49 in 72 milliseconds, of which 72 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,872] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-31 in 72 milliseconds, of which 72 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,872] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-46 in 71 milliseconds, of which 71 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,872] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-1 in 71 milliseconds, of which 71 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,872] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-16 in 71 milliseconds, of which 71 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,873] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-2 in 72 milliseconds, of which 71 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,918] INFO [Broker id=1] Finished LeaderAndIsr request in 9122ms correlationId 1 from controller 1 for 127 partitions (state.change.logger) [2021-02-17 02:24:52,919] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-47 in 117 milliseconds, of which 71 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,919] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-17 in 117 milliseconds, of which 117 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,919] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-32 in 116 milliseconds, of which 116 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,920] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-37 in 117 milliseconds, of which 116 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,920] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-7 in 102 milliseconds, of which 102 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,920] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-22 in 101 milliseconds, of which 101 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,920] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-23 in 97 milliseconds, of which 97 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,920] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-38 in 96 milliseconds, of which 96 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,921] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-8 in 97 milliseconds, of which 96 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,921] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-35 in 97 milliseconds, of which 97 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,921] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-5 in 96 milliseconds, of which 96 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,921] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-20 in 96 milliseconds, of which 96 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,921] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-21 in 96 milliseconds, of which 96 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,921] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-36 in 92 milliseconds, of which 92 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,922] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-6 in 92 milliseconds, of which 91 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,922] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-41 in 84 milliseconds, of which 84 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,922] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-10 in 83 milliseconds, of which 83 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,922] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-11 in 83 milliseconds, of which 83 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,922] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-26 in 83 milliseconds, of which 83 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,922] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-39 in 82 milliseconds, of which 82 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,922] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-9 in 82 milliseconds, of which 82 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,923] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-24 in 83 milliseconds, of which 82 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,923] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-25 in 82 milliseconds, of which 82 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:52,923] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-40 in 82 milliseconds, of which 82 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:53,032] TRACE [Controller id=1 epoch=4] Received response {error_code=0,partition_errors=[{topic_name=__consumer_offsets,partition_index=13,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=46,error_code=0,_tagged_fields={}},{topic_name=_confluent-metrics,partition_index=10,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=29,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=11,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=21,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=21,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=3,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=30,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=28,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=12,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=5,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=38,error_code=0,_tagged_fields={}},{topic_name=_confluent-metrics,partition_index=2,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=20,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=4,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=22,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=45,error_code=0,_tagged_fields={}},{topic_name=_confluent-metrics,partition_index=11,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=12,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=12,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=29,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=14,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=20,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=4,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=21,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=29,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=13,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=13,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=30,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=37,error_code=0,_tagged_fields={}},{topic_name=_confluent-metrics,partition_index=3,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=4,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=5,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=15,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=23,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=5,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=48,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=30,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=23,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=15,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=22,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=32,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=6,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=14,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=7,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=31,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=40,error_code=0,_tagged_fields={}},{topic_name=_confluent-metrics,partition_index=4,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=6,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=47,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=14,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=24,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=31,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=22,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=16,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=31,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=7,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=23,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=39,error_code=0,_tagged_fields={}},{topic_name=_confluent-metrics,partition_index=5,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=15,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=6,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=25,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=7,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=9,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=42,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=17,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=17,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=24,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=8,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=26,error_code=0,_tagged_fields={}},{topic_name=_confluent-metrics,partition_index=6,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=16,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=0,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=1,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=34,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=16,error_code=0,_tagged_fields={}},{topic_name=_schemas,partition_index=0,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=8,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=26,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=41,error_code=0,_tagged_fields={}},{topic_name=_confluent-metrics,partition_index=7,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=24,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=0,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=18,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=49,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=0,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=9,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=25,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=25,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=8,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=1,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=17,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=33,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=11,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=27,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=9,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=44,error_code=0,_tagged_fields={}},{topic_name=_confluent-metrics,partition_index=8,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=19,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=19,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=1,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=26,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=28,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=10,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=18,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=3,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=36,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=2,error_code=0,_tagged_fields={}},{topic_name=_confluent-metrics,partition_index=0,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=10,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=43,error_code=0,_tagged_fields={}},{topic_name=_confluent-metrics,partition_index=9,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=10,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=28,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=2,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=18,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=20,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=27,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=11,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=27,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=35,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_broker_samples,partition_index=3,error_code=0,_tagged_fields={}},{topic_name=_confluent-metrics,partition_index=1,error_code=0,_tagged_fields={}},{topic_name=_confluent_balancer_partition_samples,partition_index=19,error_code=0,_tagged_fields={}},{topic_name=__consumer_offsets,partition_index=2,error_code=0,_tagged_fields={}}],_tagged_fields={}} for request LEADER_AND_ISR with correlation id 1 sent to broker broker:29092 (id: 1 rack: null) (state.change.logger) [2021-02-17 02:24:53,033] INFO [Controller id=1 epoch=4] Sending UpdateMetadata request to broker 1 for 127 partitions (state.change.logger) [2021-02-17 02:24:53,213] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_schemas', partitionIndex=0, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _schemas-0 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,222] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=29, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-29 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,222] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=21, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-21 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,222] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=12, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-12 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,223] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=4, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-4 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,223] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=22, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-22 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,223] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=14, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-14 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,223] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=13, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-13 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,224] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=30, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-30 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,224] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=5, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-5 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,224] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=23, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-23 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,224] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=15, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-15 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,229] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=6, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-6 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,229] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=31, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-31 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,229] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=24, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-24 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,230] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=16, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-16 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,230] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=7, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-7 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,230] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=25, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-25 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,231] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=17, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-17 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,231] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=8, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-8 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,231] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=0, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-0 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,232] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=26, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-26 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,232] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=18, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-18 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,232] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=9, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-9 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,232] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-1 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,233] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=27, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-27 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,233] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=19, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-19 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,233] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=10, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-10 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,233] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-2 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,234] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=28, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-28 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,234] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=20, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-20 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,234] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=11, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-11 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,282] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_broker_samples', partitionIndex=3, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_broker_samples-3 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,283] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent-metrics', partitionIndex=10, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent-metrics-10 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,283] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent-metrics', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent-metrics-2 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,283] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent-metrics', partitionIndex=11, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent-metrics-11 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,284] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent-metrics', partitionIndex=3, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent-metrics-3 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,284] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent-metrics', partitionIndex=4, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent-metrics-4 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,284] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent-metrics', partitionIndex=5, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent-metrics-5 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,285] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent-metrics', partitionIndex=6, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent-metrics-6 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,285] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent-metrics', partitionIndex=7, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent-metrics-7 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,285] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent-metrics', partitionIndex=8, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent-metrics-8 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,288] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent-metrics', partitionIndex=0, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent-metrics-0 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,291] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent-metrics', partitionIndex=9, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent-metrics-9 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,292] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent-metrics', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent-metrics-1 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,292] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=11, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-11 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,292] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=3, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-3 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,293] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=28, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-28 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,293] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=20, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-20 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,293] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=12, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-12 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,293] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=29, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-29 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,294] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=4, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-4 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,294] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=21, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-21 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,298] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=13, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-13 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,337] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=5, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-5 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,337] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=30, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-30 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,338] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=22, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-22 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,341] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=14, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-14 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,342] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=6, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-6 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,342] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=31, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-31 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,342] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=23, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-23 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,342] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=15, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-15 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,343] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=7, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-7 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,343] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=24, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-24 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,343] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=16, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-16 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,343] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=8, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-8 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,344] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=0, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-0 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,344] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=25, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-25 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,344] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=17, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-17 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,344] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=9, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-9 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,381] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-1 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,382] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=26, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-26 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,382] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=18, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-18 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,382] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=10, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-10 in response to UpdateMetadata request sent by co ntroller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,382] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-2 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,383] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=27, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-27 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,383] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='_confluent_balancer_partition_samples', partitionIndex=19, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition _confluent_balancer_partition_samples-19 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,383] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=13, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-13 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,383] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=46, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-46 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,384] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=21, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-21 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,384] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=30, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-30 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,384] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=5, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-5 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,384] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=38, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-38 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,384] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=45, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-45 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,385] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=12, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-12 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,385] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=20, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-20 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,385] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=29, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-29 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,385] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=37, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-37 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,386] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=4, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-4 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,386] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=15, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-15 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,386] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=48, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-48 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,386] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=23, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-23 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,386] INFO Static member MemberMetadata(memberId=sr-1-9bdaac3b-256b-48e0-8840-1e50ea0011b7, groupInstanceId=Some(null), clientId=sr-1, clientHost=/172.22.0.9, sessionTimeoutMs=10000, rebalanceTimeoutMs=300000, supportedProtocols=List(v0), ).groupInstanceId of group schema-registry loaded with member id sr-1-9bdaac3b-256b-48e0-8840-1e50ea0011b7 at generation 1. (kafka.coordinator.group.GroupMetadata$) [2021-02-17 02:24:53,387] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=32, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-32 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,387] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=7, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-7 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,483] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=40, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-40 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,484] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=47, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-47 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,487] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=14, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-14 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,488] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=22, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-22 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,488] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=31, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-31 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,488] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=39, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-39 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,489] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=6, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-6 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,499] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=9, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-9 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,500] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=42, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-42 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,500] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=17, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-17 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,501] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=26, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-26 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,501] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-1 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,501] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=34, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-34 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,501] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=16, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-16 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,502] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=41, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-41 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,509] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=24, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-24 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,510] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=49, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-49 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,510] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=0, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-0 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,510] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=25, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-25 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,510] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=8, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-8 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,511] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=33, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-33 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,511] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=11, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-11 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,511] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=44, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-44 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,511] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=19, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-19 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,512] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=28, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-28 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,512] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=3, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-3 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,512] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=36, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-36 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,523] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=43, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-43 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,524] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=10, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-10 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,524] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=18, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-18 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,473] INFO Static member MemberMetadata(memberId=sr-1-c90315da-78b5-4168-ad3c-ded5838c7245, groupInstanceId=Some(null), clientId=sr-1, clientHost=/172.22.0.4, sessionTimeoutMs=10000, rebalanceTimeoutMs=300000, supportedProtocols=List(v0), ).groupInstanceId of group schema-registry loaded with member id sr-1-c90315da-78b5-4168-ad3c-ded5838c7245 at generation 3. (kafka.coordinator.group.GroupMetadata$) [2021-02-17 02:24:53,528] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=27, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-27 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,528] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=35, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-35 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,528] TRACE [Broker id=1] Cached leader info UpdateMetadataPartitionState(topicName='__consumer_offsets', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], observers=[], offlineReplicas=[]) for partition __consumer_offsets-2 in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,549] INFO [Broker id=1] Add 127 partitions and deleted 0 partitions from metadata cache in response to UpdateMetadata request sent by controller 1 epoch 4 with correlation id 2 (state.change.logger) [2021-02-17 02:24:53,570] INFO [GroupCoordinator 1]: Loading group metadata for schema-registry with generation 3 (kafka.coordinator.group.GroupCoordinator) [2021-02-17 02:24:53,589] TRACE [Controller id=1 epoch=4] Received response {error_code=0,_tagged_fields={}} for request UPDATE_METADATA with correlation id 2 sent to broker broker:29092 (id: 1 rack: null) (state.change.logger) [2021-02-17 02:24:53,883] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-29 in 1035 milliseconds, of which 75 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:53,884] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-44 in 1036 milliseconds, of which 1036 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:53,884] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-14 in 1035 milliseconds, of which 1035 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:53,884] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-45 in 1035 milliseconds, of which 1035 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:53,884] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-15 in 1035 milliseconds, of which 1035 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:53,885] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-30 in 1035 milliseconds, of which 1034 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:53,885] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-0 in 1035 milliseconds, of which 1035 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:53,885] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-27 in 1035 milliseconds, of which 1035 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:53,885] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-42 in 1034 milliseconds, of which 1034 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:53,885] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-12 in 1027 milliseconds, of which 1027 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:53,886] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-43 in 1026 milliseconds, of which 1026 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:53,886] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-13 in 1027 milliseconds, of which 1027 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:53,886] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-28 in 1026 milliseconds, of which 1026 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2021-02-17 02:24:55,259] INFO Waiting for 8 seconds for metric reporter topic _confluent-telemetry-metrics to become available. (io.confluent.cruisecontrol.metricsreporter.ConfluentMetricsSamplerBase) [2021-02-17 02:24:56,100] INFO AdminClientConfig values: bootstrap.servers = [broker:29092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 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 = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 127000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null 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.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 (org.apache.kafka.clients.admin.AdminClientConfig) [2021-02-17 02:24:56,129] WARN The configuration 'topic.replicas' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig) [2021-02-17 02:24:56,178] INFO Kafka version: 6.1.0-ce (org.apache.kafka.common.utils.AppInfoParser) [2021-02-17 02:24:56,179] INFO Kafka commitId: d19b95317d02f231 (org.apache.kafka.common.utils.AppInfoParser) [2021-02-17 02:24:56,179] INFO Kafka startTimeMs: 1613528696178 (org.apache.kafka.common.utils.AppInfoParser) [2021-02-17 02:24:56,326] INFO jetty-9.4.33.v20201020; built: 2020-10-20T23:39:24.803Z; git: 1be68755656cef678b79a2ef1c2ebbca99e25420; jvm 11.0.10+9-LTS (org.eclipse.jetty.server.Server) [2021-02-17 02:24:56,539] INFO App info kafka.admin.client for adminclient-1 unregistered (org.apache.kafka.common.utils.AppInfoParser) [2021-02-17 02:24:56,562] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:24:56,588] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:24:56,588] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:24:58,501] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session) [2021-02-17 02:24:58,501] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session) [2021-02-17 02:24:58,587] INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session) [2021-02-17 02:25:03,480] INFO Waiting for 16 seconds for metric reporter topic _confluent-telemetry-metrics to become available. (io.confluent.cruisecontrol.metricsreporter.ConfluentMetricsSamplerBase) [2021-02-17 02:25:04,082] INFO [GroupCoordinator 1]: Member sr-1-c90315da-78b5-4168-ad3c-ded5838c7245 in group schema-registry has failed, removing it from the group (kafka.coordinator.group.GroupCoordinator) [2021-02-17 02:25:04,089] INFO [GroupCoordinator 1]: Preparing to rebalance group schema-registry in state PreparingRebalance with old generation 3 (__consumer_offsets-29) (reason: removing member sr-1-c90315da-78b5-4168-ad3c-ded5838c7245 on heartbeat expiration) (kafka.coordinator.group.GroupCoordinator) [2021-02-17 02:25:04,204] INFO [GroupCoordinator 1]: Group schema-registry with generation 4 is now empty (__consumer_offsets-29) (kafka.coordinator.group.GroupCoordinator) Feb 17, 2021 2:25:10 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider io.confluent.metadataapi.resources.MetadataResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider io.confluent.metadataapi.resources.MetadataResource will be ignored. [2021-02-17 02:25:13,289] INFO [GroupCoordinator 1]: Preparing to rebalance group schema-registry in state PreparingRebalance with old generation 4 (__consumer_offsets-29) (reason: Adding new member sr-1-769d7049-112e-4a4c-9102-8ad656fc9967 with group instance id None) (kafka.coordinator.group.GroupCoordinator) [2021-02-17 02:25:13,386] INFO [GroupCoordinator 1]: Stabilized group schema-registry generation 5 (__consumer_offsets-29) (kafka.coordinator.group.GroupCoordinator) [2021-02-17 02:25:13,682] INFO [GroupCoordinator 1]: Assignment received from leader for group schema-registry for generation 5 (kafka.coordinator.group.GroupCoordinator) [2021-02-17 02:25:14,166] INFO HV000001: Hibernate Validator 6.0.17.Final (org.hibernate.validator.internal.util.Version) [2021-02-17 02:25:17,326] INFO Started o.e.j.s.ServletContextHandler@58543b54{/v1/metadata,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler) [2021-02-17 02:25:18,701] ERROR [KafkaServer id=1] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) java.lang.IllegalStateException: Kafka HTTP server failed to start up. at kafka.server.KafkaServer.startup(KafkaServer.scala:656) at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44) at kafka.Kafka$.main(Kafka.scala:82) at kafka.Kafka.main(Kafka.scala) [2021-02-17 02:25:18,705] INFO [KafkaServer id=1] shutting down (kafka.server.KafkaServer) [2021-02-17 02:25:19,745] INFO Waiting for 32 seconds for metric reporter topic _confluent-telemetry-metrics to become available. (io.confluent.cruisecontrol.metricsreporter.ConfluentMetricsSamplerBase) [2021-02-17 02:25:25,430] INFO Started o.e.j.s.ServletContextHandler@1f19ece1{/kafka,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler) [2021-02-17 02:25:26,401] INFO Started o.e.j.s.ServletContextHandler@494ee60c{/ws,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler) [2021-02-17 02:25:26,451] INFO Started o.e.j.s.ServletContextHandler@67a90208{/ws,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler) [2021-02-17 02:25:27,269] INFO Started NetworkTrafficServerConnector@5382184b{HTTP/1.1, (http/1.1)}{0.0.0.0:8090} (org.eclipse.jetty.server.AbstractConnector) [2021-02-17 02:25:27,269] INFO Started @97650ms (org.eclipse.jetty.server.Server) [2021-02-17 02:25:27,281] INFO KafkaHttpServer transitioned from STARTING to RUNNING.. (io.confluent.http.server.KafkaHttpServerImpl) [2021-02-17 02:25:27,312] INFO KafkaHttpServer transitioned from RUNNING to STOPPING.. (io.confluent.http.server.KafkaHttpServerImpl) [2021-02-17 02:25:27,367] INFO Stopped NetworkTrafficServerConnector@5382184b{HTTP/1.1, (http/1.1)}{0.0.0.0:8090} (org.eclipse.jetty.server.AbstractConnector) [2021-02-17 02:25:27,368] INFO node0 Stopped scavenging (org.eclipse.jetty.server.session) [2021-02-17 02:25:27,385] INFO Stopped o.e.j.s.ServletContextHandler@67a90208{/ws,null,STOPPED} (org.eclipse.jetty.server.handler.ContextHandler) [2021-02-17 02:25:27,387] INFO Stopped o.e.j.s.ServletContextHandler@494ee60c{/ws,null,STOPPED} (org.eclipse.jetty.server.handler.ContextHandler) [2021-02-17 02:25:27,484] INFO Stopped o.e.j.s.ServletContextHandler@1f19ece1{/kafka,null,STOPPED} (org.eclipse.jetty.server.handler.ContextHandler) [2021-02-17 02:25:27,819] INFO Stopped o.e.j.s.ServletContextHandler@58543b54{/v1/metadata,null,STOPPED} (org.eclipse.jetty.server.handler.ContextHandler) [2021-02-17 02:25:27,863] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:27,874] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:27,879] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:27,920] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:27,924] INFO Closing reporter io.confluent.telemetry.reporter.TelemetryReporter (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:27,925] INFO Stopping TelemetryReporter collectorTask (io.confluent.telemetry.reporter.TelemetryReporter) [2021-02-17 02:25:27,925] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:27,926] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:27,926] INFO KafkaHttpServer transitioned from STOPPING to TERMINATED.. (io.confluent.http.server.KafkaHttpServerImpl) [2021-02-17 02:25:27,935] INFO [/config/changes-event-process-thread]: Shutting down (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread) [2021-02-17 02:25:27,939] INFO [/config/changes-event-process-thread]: Stopped (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread) [2021-02-17 02:25:27,944] INFO [/config/changes-event-process-thread]: Shutdown completed (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread) [2021-02-17 02:25:27,945] INFO [SocketServer brokerId=1] Stopping socket server request processors (kafka.network.SocketServer) [2021-02-17 02:25:28,299] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:28,576] INFO [SocketServer brokerId=1] Stopped socket server request processors (kafka.network.SocketServer) [2021-02-17 02:25:28,587] WARN [Producer clientId=ConfluentBalancerSampleStoreProducer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:28,405] WARN [Producer clientId=confluent-telemetry-reporter-local-producer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:28,622] INFO [data-plane Kafka Request Handler on Broker 1], shutting down (kafka.server.KafkaRequestHandlerPool) [2021-02-17 02:25:28,681] INFO [data-plane Kafka Request Handler on Broker 1], shut down completely (kafka.server.KafkaRequestHandlerPool) [2021-02-17 02:25:28,702] INFO [ExpirationReaper-1-AlterAcls]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:28,765] INFO [ExpirationReaper-1-AlterAcls]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:28,766] INFO [ExpirationReaper-1-AlterAcls]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:28,801] INFO [KafkaApi-1] Shutdown complete. (kafka.server.KafkaApis) [2021-02-17 02:25:28,802] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:28,818] INFO [ExpirationReaper-1-topic]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:28,926] WARN [Producer clientId=confluent-telemetry-reporter-local-producer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:28,976] INFO [ExpirationReaper-1-topic]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:28,976] INFO [ExpirationReaper-1-topic]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:28,992] INFO [TransactionCoordinator id=1] Shutting down. (kafka.coordinator.transaction.TransactionCoordinator) [2021-02-17 02:25:29,024] INFO [ProducerId Manager 1]: Shutdown complete: last producerId assigned 3000 (kafka.coordinator.transaction.ProducerIdManager) [2021-02-17 02:25:29,026] INFO [Transaction State Manager 1]: Shutdown complete (kafka.coordinator.transaction.TransactionStateManager) [2021-02-17 02:25:29,026] INFO [Transaction Marker Channel Manager 1]: Shutting down (kafka.coordinator.transaction.TransactionMarkerChannelManager) [2021-02-17 02:25:29,027] INFO [Transaction Marker Channel Manager 1]: Stopped (kafka.coordinator.transaction.TransactionMarkerChannelManager) [2021-02-17 02:25:29,028] INFO [Transaction Marker Channel Manager 1]: Shutdown completed (kafka.coordinator.transaction.TransactionMarkerChannelManager) [2021-02-17 02:25:29,036] INFO [TransactionCoordinator id=1] Shutdown complete. (kafka.coordinator.transaction.TransactionCoordinator) [2021-02-17 02:25:29,081] INFO [GroupCoordinator 1]: Shutting down. (kafka.coordinator.group.GroupCoordinator) [2021-02-17 02:25:29,083] INFO [ExpirationReaper-1-Heartbeat]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,098] WARN [Producer clientId=ConfluentBalancerSampleStoreProducer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:29,129] INFO [ExpirationReaper-1-Heartbeat]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,129] INFO [ExpirationReaper-1-Heartbeat]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,149] INFO [ExpirationReaper-1-Rebalance]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,183] INFO [ExpirationReaper-1-Rebalance]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,184] INFO [ExpirationReaper-1-Rebalance]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,185] INFO [GroupCoordinator 1]: Shutdown complete. (kafka.coordinator.group.GroupCoordinator) [2021-02-17 02:25:29,188] INFO [ReplicaManager broker=1] Shutting down (kafka.server.ReplicaManager) [2021-02-17 02:25:29,230] INFO [LogDirFailureHandler]: Shutting down (kafka.server.ReplicaManager$LogDirFailureHandler) [2021-02-17 02:25:29,254] INFO [LogDirFailureHandler]: Stopped (kafka.server.ReplicaManager$LogDirFailureHandler) [2021-02-17 02:25:29,255] INFO [LogDirFailureHandler]: Shutdown completed (kafka.server.ReplicaManager$LogDirFailureHandler) [2021-02-17 02:25:29,256] INFO [ReplicaFetcherManager on broker 1] shutting down (kafka.server.ReplicaFetcherManager) [2021-02-17 02:25:29,274] INFO [ReplicaFetcherManager on broker 1] shutdown completed (kafka.server.ReplicaFetcherManager) [2021-02-17 02:25:29,279] INFO [ReplicaAlterLogDirsManager on broker 1] shutting down (kafka.server.ReplicaAlterLogDirsManager) [2021-02-17 02:25:29,279] INFO [ReplicaAlterLogDirsManager on broker 1] shutdown completed (kafka.server.ReplicaAlterLogDirsManager) [2021-02-17 02:25:29,279] INFO [ExpirationReaper-1-Fetch]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,305] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:29,308] INFO [ExpirationReaper-1-Fetch]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,308] INFO [ExpirationReaper-1-Fetch]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,309] INFO [ExpirationReaper-1-Produce]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,389] INFO [ExpirationReaper-1-Produce]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,412] INFO [ExpirationReaper-1-Produce]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,413] INFO [ExpirationReaper-1-DeleteRecords]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,432] WARN [Producer clientId=confluent-telemetry-reporter-local-producer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:29,590] INFO [ExpirationReaper-1-DeleteRecords]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,599] INFO [ExpirationReaper-1-DeleteRecords]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,600] INFO [ExpirationReaper-1-ElectLeader]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,616] WARN [Producer clientId=ConfluentBalancerSampleStoreProducer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:29,790] INFO [ExpirationReaper-1-ElectLeader]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,791] INFO [ExpirationReaper-1-ElectLeader]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,791] INFO [ExpirationReaper-1-ListOffsets]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,791] INFO [ExpirationReaper-1-ListOffsets]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,792] INFO [ExpirationReaper-1-ListOffsets]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-02-17 02:25:29,806] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:29,879] INFO [ReplicaManager broker=1] Shut down completely (kafka.server.ReplicaManager) [2021-02-17 02:25:29,892] INFO [broker-1-to-controller-send-thread]: Shutting down (kafka.server.BrokerToControllerRequestThread) [2021-02-17 02:25:29,898] INFO [broker-1-to-controller-send-thread]: Stopped (kafka.server.BrokerToControllerRequestThread) [2021-02-17 02:25:29,908] INFO [broker-1-to-controller-send-thread]: Shutdown completed (kafka.server.BrokerToControllerRequestThread) [2021-02-17 02:25:29,908] INFO [broker-1-to-controller-send-thread]: Shutdown completed (kafka.server.BrokerToControllerRequestThread) [2021-02-17 02:25:29,909] INFO Shutting down. (kafka.log.LogManager) [2021-02-17 02:25:29,915] INFO Shutting down the log cleaner. (kafka.log.LogCleaner) [2021-02-17 02:25:29,937] WARN [Producer clientId=confluent-telemetry-reporter-local-producer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:29,937] INFO [kafka-log-cleaner-thread-0]: Shutting down (kafka.log.LogCleaner) [2021-02-17 02:25:29,938] INFO [kafka-log-cleaner-thread-0]: Stopped (kafka.log.LogCleaner) [2021-02-17 02:25:29,938] INFO [kafka-log-cleaner-thread-0]: Shutdown completed (kafka.log.LogCleaner) [2021-02-17 02:25:30,119] WARN [Producer clientId=ConfluentBalancerSampleStoreProducer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:30,119] INFO Tier partition state for _confluent_balancer_partition_samples-25 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:30,252] INFO Closing log for _confluent_balancer_partition_samples took 204 ms. (kafka.log.LogManager) [2021-02-17 02:25:30,401] INFO Tier partition state for __consumer_offsets-43 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:30,404] INFO Closing log for __consumer_offsets took 150 ms. (kafka.log.LogManager) [2021-02-17 02:25:30,464] WARN [Producer clientId=confluent-telemetry-reporter-local-producer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:30,503] INFO Tier partition state for __consumer_offsets-30 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:30,523] INFO Closing log for __consumer_offsets took 118 ms. (kafka.log.LogManager) [2021-02-17 02:25:30,562] INFO Tier partition state for _confluent_balancer_partition_samples-11 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:30,567] INFO Closing log for _confluent_balancer_partition_samples took 43 ms. (kafka.log.LogManager) [2021-02-17 02:25:30,624] WARN [Producer clientId=ConfluentBalancerSampleStoreProducer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:30,634] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:30,650] INFO Tier partition state for __consumer_offsets-32 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:30,666] INFO Closing log for __consumer_offsets took 99 ms. (kafka.log.LogManager) [2021-02-17 02:25:30,766] INFO Tier partition state for _confluent_balancer_partition_samples-19 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:30,781] INFO Closing log for _confluent_balancer_partition_samples took 114 ms. (kafka.log.LogManager) [2021-02-17 02:25:30,874] INFO Tier partition state for __consumer_offsets-25 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:30,891] INFO Closing log for __consumer_offsets took 109 ms. (kafka.log.LogManager) [2021-02-17 02:25:30,991] INFO Tier partition state for _confluent_balancer_partition_samples-23 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:31,007] INFO Closing log for _confluent_balancer_partition_samples took 116 ms. (kafka.log.LogManager) [2021-02-17 02:25:31,078] INFO Tier partition state for _confluent_balancer_broker_samples-20 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:31,086] INFO Closing log for _confluent_balancer_broker_samples took 78 ms. (kafka.log.LogManager) [2021-02-17 02:25:31,168] INFO Tier partition state for __consumer_offsets-41 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:31,182] INFO Closing log for __consumer_offsets took 94 ms. (kafka.log.LogManager) [2021-02-17 02:25:31,258] INFO Tier partition state for _confluent_balancer_broker_samples-7 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:31,283] INFO Closing log for _confluent_balancer_broker_samples took 100 ms. (kafka.log.LogManager) [2021-02-17 02:25:31,286] WARN [Producer clientId=ConfluentBalancerSampleStoreProducer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:31,338] WARN [Producer clientId=confluent-telemetry-reporter-local-producer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:31,372] INFO Tier partition state for _confluent_balancer_broker_samples-4 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:31,388] INFO Closing log for _confluent_balancer_broker_samples took 104 ms. (kafka.log.LogManager) [2021-02-17 02:25:31,479] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:31,552] INFO Tier partition state for _confluent_balancer_broker_samples-17 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:31,555] INFO Closing log for _confluent_balancer_broker_samples took 166 ms. (kafka.log.LogManager) [2021-02-17 02:25:31,598] INFO Tier partition state for __consumer_offsets-49 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:31,615] INFO Closing log for __consumer_offsets took 59 ms. (kafka.log.LogManager) [2021-02-17 02:25:31,634] INFO Tier partition state for _confluent_balancer_partition_samples-10 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:31,647] INFO Closing log for _confluent_balancer_partition_samples took 33 ms. (kafka.log.LogManager) [2021-02-17 02:25:31,715] INFO Tier partition state for _confluent_balancer_partition_samples-28 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:31,724] INFO Closing log for _confluent_balancer_partition_samples took 76 ms. (kafka.log.LogManager) [2021-02-17 02:25:31,781] INFO Tier partition state for __consumer_offsets-40 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:31,796] INFO Closing log for __consumer_offsets took 62 ms. (kafka.log.LogManager) [2021-02-17 02:25:31,840] INFO Tier partition state for _confluent_balancer_broker_samples-16 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:31,842] INFO Closing log for _confluent_balancer_broker_samples took 45 ms. (kafka.log.LogManager) [2021-02-17 02:25:31,877] INFO Tier partition state for __consumer_offsets-27 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:31,889] INFO Closing log for __consumer_offsets took 47 ms. (kafka.log.LogManager) [2021-02-17 02:25:31,959] INFO Tier partition state for _confluent_balancer_broker_samples-8 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:31,980] INFO Closing log for _confluent_balancer_broker_samples took 88 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,027] INFO Tier partition state for _confluent_balancer_partition_samples-1 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,043] INFO Closing log for _confluent_balancer_partition_samples took 62 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,111] INFO Tier partition state for _confluent_balancer_broker_samples-28 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,140] INFO Closing log for _confluent_balancer_broker_samples took 95 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,266] INFO Tier partition state for _confluent_balancer_broker_samples-27 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,277] INFO Closing log for _confluent_balancer_broker_samples took 137 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,370] INFO Tier partition state for _confluent-metrics-6 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,371] INFO [ProducerStateManager partition=_confluent-metrics-6] Writing producer snapshot at offset 3 (kafka.log.ProducerStateManager) [2021-02-17 02:25:32,387] INFO Closing log for _confluent-metrics took 109 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,465] WARN [Producer clientId=confluent-telemetry-reporter-local-producer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:32,465] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:32,498] INFO Tier partition state for _confluent_balancer_partition_samples-29 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,514] INFO Closing log for _confluent_balancer_partition_samples took 127 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,514] INFO Tier partition state for _confluent-metrics-9 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,518] INFO Closing log for _confluent-metrics took 4 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,566] INFO Tier partition state for _confluent_balancer_broker_samples-12 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,571] INFO Closing log for _confluent_balancer_broker_samples took 53 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,583] INFO Tier partition state for _confluent-metrics-11 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,583] INFO [ProducerStateManager partition=_confluent-metrics-11] Writing producer snapshot at offset 4 (kafka.log.ProducerStateManager) [2021-02-17 02:25:32,586] INFO Closing log for _confluent-metrics took 16 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,602] INFO Tier partition state for __consumer_offsets-12 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,603] INFO Closing log for __consumer_offsets took 16 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,634] INFO Tier partition state for _confluent_balancer_broker_samples-24 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,636] INFO Closing log for _confluent_balancer_broker_samples took 33 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,678] INFO Tier partition state for __consumer_offsets-36 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,682] INFO Closing log for __consumer_offsets took 47 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,733] INFO Tier partition state for __consumer_offsets-45 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,736] INFO Closing log for __consumer_offsets took 53 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,786] INFO Tier partition state for _confluent_balancer_broker_samples-25 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,788] INFO Closing log for _confluent_balancer_broker_samples took 51 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,823] INFO Tier partition state for _confluent_balancer_partition_samples-20 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,826] INFO Closing log for _confluent_balancer_partition_samples took 37 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,875] INFO Tier partition state for _confluent_balancer_broker_samples-29 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,878] INFO Closing log for _confluent_balancer_broker_samples took 51 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,938] INFO Tier partition state for _confluent_balancer_broker_samples-31 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,949] INFO Closing log for _confluent_balancer_broker_samples took 70 ms. (kafka.log.LogManager) [2021-02-17 02:25:32,984] INFO Tier partition state for _confluent_balancer_partition_samples-16 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:32,985] WARN [Producer clientId=ConfluentBalancerSampleStoreProducer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:32,986] INFO Closing log for _confluent_balancer_partition_samples took 37 ms. (kafka.log.LogManager) [2021-02-17 02:25:33,027] INFO Tier partition state for _confluent_balancer_partition_samples-27 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:33,034] INFO Closing log for _confluent_balancer_partition_samples took 47 ms. (kafka.log.LogManager) [2021-02-17 02:25:33,034] INFO Tier partition state for _confluent-metrics-10 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:33,043] INFO Closing log for _confluent-metrics took 9 ms. (kafka.log.LogManager) [2021-02-17 02:25:33,110] INFO Tier partition state for _confluent_balancer_broker_samples-19 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:33,113] INFO Closing log for _confluent_balancer_broker_samples took 69 ms. (kafka.log.LogManager) [2021-02-17 02:25:33,153] INFO Tier partition state for __consumer_offsets-20 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:33,155] INFO Closing log for __consumer_offsets took 43 ms. (kafka.log.LogManager) [2021-02-17 02:25:33,233] INFO Tier partition state for _confluent-metrics-5 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:33,233] INFO [ProducerStateManager partition=_confluent-metrics-5] Writing producer snapshot at offset 3 (kafka.log.ProducerStateManager) [2021-02-17 02:25:33,241] INFO Closing log for _confluent-metrics took 85 ms. (kafka.log.LogManager) [2021-02-17 02:25:33,315] INFO Tier partition state for __consumer_offsets-18 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:33,319] INFO Closing log for __consumer_offsets took 77 ms. (kafka.log.LogManager) [2021-02-17 02:25:33,359] INFO Tier partition state for _confluent_balancer_broker_samples-3 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:33,371] INFO Closing log for _confluent_balancer_broker_samples took 51 ms. (kafka.log.LogManager) [2021-02-17 02:25:33,427] INFO Tier partition state for __consumer_offsets-48 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:33,435] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:33,435] INFO Closing log for __consumer_offsets took 64 ms. (kafka.log.LogManager) [2021-02-17 02:25:33,482] INFO Tier partition state for _confluent_balancer_partition_samples-18 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:33,484] INFO Closing log for _confluent_balancer_partition_samples took 48 ms. (kafka.log.LogManager) [2021-02-17 02:25:33,528] WARN [Producer clientId=confluent-telemetry-reporter-local-producer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:33,615] INFO Tier partition state for _confluent_balancer_partition_samples-7 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:33,657] INFO Closing log for _confluent_balancer_partition_samples took 173 ms. (kafka.log.LogManager) [2021-02-17 02:25:33,753] INFO Tier partition state for _confluent_balancer_broker_samples-0 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:33,757] INFO Closing log for _confluent_balancer_broker_samples took 100 ms. (kafka.log.LogManager) [2021-02-17 02:25:33,828] INFO Tier partition state for _confluent-metrics-1 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:33,829] INFO [ProducerStateManager partition=_confluent-metrics-1] Writing producer snapshot at offset 6 (kafka.log.ProducerStateManager) [2021-02-17 02:25:33,844] INFO Closing log for _confluent-metrics took 87 ms. (kafka.log.LogManager) [2021-02-17 02:25:33,925] INFO Tier partition state for __consumer_offsets-10 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:33,941] INFO Closing log for __consumer_offsets took 96 ms. (kafka.log.LogManager) [2021-02-17 02:25:33,986] INFO Tier partition state for _confluent_balancer_broker_samples-30 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:33,990] INFO Closing log for _confluent_balancer_broker_samples took 48 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,053] INFO Tier partition state for __consumer_offsets-11 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,058] INFO Closing log for __consumer_offsets took 67 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,137] INFO Tier partition state for _confluent_balancer_partition_samples-2 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,139] INFO Closing log for _confluent_balancer_partition_samples took 81 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,170] INFO Tier partition state for _confluent-metrics-0 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,170] INFO [ProducerStateManager partition=_confluent-metrics-0] Writing producer snapshot at offset 10 (kafka.log.ProducerStateManager) [2021-02-17 02:25:34,173] INFO Closing log for _confluent-metrics took 34 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,207] INFO Tier partition state for __consumer_offsets-23 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,224] INFO Closing log for __consumer_offsets took 50 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,259] INFO Tier partition state for _confluent_balancer_partition_samples-30 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,263] INFO Closing log for _confluent_balancer_partition_samples took 38 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,324] INFO Tier partition state for __consumer_offsets-42 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,328] INFO Closing log for __consumer_offsets took 65 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,347] WARN [Producer clientId=confluent-telemetry-reporter-local-producer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:34,409] INFO Tier partition state for _confluent_balancer_broker_samples-14 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,416] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:34,417] INFO Closing log for _confluent_balancer_broker_samples took 88 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,479] INFO Tier partition state for __consumer_offsets-28 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,490] INFO Closing log for __consumer_offsets took 73 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,551] INFO Tier partition state for __consumer_offsets-4 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,557] INFO Closing log for __consumer_offsets took 67 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,602] INFO Tier partition state for _confluent_balancer_partition_samples-22 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,604] INFO Closing log for _confluent_balancer_partition_samples took 47 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,647] INFO Tier partition state for _confluent_balancer_partition_samples-14 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,649] INFO Closing log for _confluent_balancer_partition_samples took 43 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,701] INFO Tier partition state for __consumer_offsets-1 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,704] INFO Closing log for __consumer_offsets took 54 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,734] INFO Tier partition state for __consumer_offsets-38 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,739] INFO Closing log for __consumer_offsets took 34 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,821] INFO Tier partition state for __consumer_offsets-14 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,832] INFO Closing log for __consumer_offsets took 93 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,892] INFO Tier partition state for _confluent_balancer_partition_samples-6 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,900] INFO Closing log for _confluent_balancer_partition_samples took 67 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,959] INFO Tier partition state for _confluent_balancer_broker_samples-6 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,963] INFO Closing log for _confluent_balancer_broker_samples took 63 ms. (kafka.log.LogManager) [2021-02-17 02:25:34,971] INFO Tier partition state for __consumer_offsets-29 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:34,972] INFO [ProducerStateManager partition=__consumer_offsets-29] Writing producer snapshot at offset 5 (kafka.log.ProducerStateManager) [2021-02-17 02:25:34,986] INFO Closing log for __consumer_offsets took 22 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,071] INFO Tier partition state for _confluent_balancer_partition_samples-13 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,073] INFO Closing log for _confluent_balancer_partition_samples took 86 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,110] INFO Tier partition state for __consumer_offsets-6 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,111] INFO Closing log for __consumer_offsets took 38 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,145] INFO Tier partition state for __consumer_offsets-0 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,147] INFO Closing log for __consumer_offsets took 35 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,177] INFO Tier partition state for _confluent_balancer_broker_samples-13 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,178] INFO Closing log for _confluent_balancer_broker_samples took 31 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,228] INFO Tier partition state for _confluent_balancer_partition_samples-26 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,230] INFO Closing log for _confluent_balancer_partition_samples took 51 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,266] INFO Tier partition state for __consumer_offsets-13 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,272] INFO Closing log for __consumer_offsets took 42 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,323] INFO Tier partition state for __consumer_offsets-26 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,333] INFO Closing log for __consumer_offsets took 60 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,355] INFO Tier partition state for __consumer_offsets-21 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,356] INFO Closing log for __consumer_offsets took 22 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,373] INFO Tier partition state for __consumer_offsets-19 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,376] INFO Closing log for __consumer_offsets took 20 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,466] WARN [Producer clientId=confluent-telemetry-reporter-local-producer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:35,469] INFO Tier partition state for __consumer_offsets-33 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,495] INFO Closing log for __consumer_offsets took 118 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,550] INFO Tier partition state for __consumer_offsets-37 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,552] INFO Closing log for __consumer_offsets took 57 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,573] INFO Tier partition state for __consumer_offsets-8 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,581] INFO Closing log for __consumer_offsets took 29 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,596] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:35,632] INFO Tier partition state for __consumer_offsets-24 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,644] INFO Closing log for __consumer_offsets took 63 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,688] INFO Tier partition state for _confluent_balancer_broker_samples-9 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,689] INFO Closing log for _confluent_balancer_broker_samples took 45 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,763] INFO Tier partition state for _confluent_balancer_broker_samples-26 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,767] INFO Closing log for _confluent_balancer_broker_samples took 77 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,862] INFO Tier partition state for __consumer_offsets-3 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,901] INFO Closing log for __consumer_offsets took 134 ms. (kafka.log.LogManager) [2021-02-17 02:25:35,970] INFO Tier partition state for __consumer_offsets-35 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:35,980] INFO Closing log for __consumer_offsets took 79 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,014] INFO Tier partition state for __consumer_offsets-17 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,015] INFO Closing log for __consumer_offsets took 34 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,057] INFO Tier partition state for __consumer_offsets-39 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,058] INFO Closing log for __consumer_offsets took 43 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,073] INFO Tier partition state for _confluent_balancer_broker_samples-10 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,075] INFO Closing log for _confluent_balancer_broker_samples took 18 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,106] INFO Tier partition state for _confluent_balancer_partition_samples-0 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,108] INFO Closing log for _confluent_balancer_partition_samples took 32 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,123] INFO Tier partition state for _confluent_balancer_broker_samples-15 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,124] INFO Closing log for _confluent_balancer_broker_samples took 16 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,140] INFO Tier partition state for _confluent_balancer_broker_samples-23 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,141] INFO Closing log for _confluent_balancer_broker_samples took 17 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,164] INFO Tier partition state for _confluent_balancer_partition_samples-12 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,165] INFO Closing log for _confluent_balancer_partition_samples took 24 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,187] INFO Tier partition state for _confluent_balancer_broker_samples-1 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,188] INFO Closing log for _confluent_balancer_broker_samples took 23 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,190] INFO Tier partition state for _confluent-metrics-3 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,190] INFO [ProducerStateManager partition=_confluent-metrics-3] Writing producer snapshot at offset 9 (kafka.log.ProducerStateManager) [2021-02-17 02:25:36,202] INFO Closing log for _confluent-metrics took 14 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,236] INFO Tier partition state for _confluent_balancer_partition_samples-8 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,237] INFO Closing log for _confluent_balancer_partition_samples took 34 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,270] INFO Tier partition state for _confluent-metrics-4 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,272] INFO Closing log for _confluent-metrics took 35 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,298] INFO Tier partition state for __consumer_offsets-16 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,300] INFO Closing log for __consumer_offsets took 28 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,323] INFO Tier partition state for _confluent_balancer_broker_samples-5 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,325] INFO Closing log for _confluent_balancer_broker_samples took 25 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,348] INFO Tier partition state for __consumer_offsets-44 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,350] INFO Closing log for __consumer_offsets took 25 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,356] INFO Tier partition state for _schemas-0 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,356] INFO [ProducerStateManager partition=_schemas-0] Writing producer snapshot at offset 7 (kafka.log.ProducerStateManager) [2021-02-17 02:25:36,372] INFO Closing log for _schemas took 22 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,421] INFO Tier partition state for _confluent_balancer_partition_samples-24 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,423] INFO Closing log for _confluent_balancer_partition_samples took 51 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,433] INFO Tier partition state for _confluent-metrics-7 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,433] INFO [ProducerStateManager partition=_confluent-metrics-7] Writing producer snapshot at offset 8 (kafka.log.ProducerStateManager) [2021-02-17 02:25:36,447] INFO Closing log for _confluent-metrics took 24 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,467] WARN [Producer clientId=ConfluentBalancerSampleStoreProducer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:36,515] INFO Tier partition state for _confluent_balancer_partition_samples-3 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,523] INFO Closing log for _confluent_balancer_partition_samples took 75 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,565] INFO Tier partition state for __consumer_offsets-47 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,570] INFO Closing log for __consumer_offsets took 47 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,572] INFO Tier partition state for _confluent-metrics-2 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,572] INFO [ProducerStateManager partition=_confluent-metrics-2] Writing producer snapshot at offset 6 (kafka.log.ProducerStateManager) [2021-02-17 02:25:36,576] WARN [Producer clientId=confluent-telemetry-reporter-local-producer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:36,579] INFO Closing log for _confluent-metrics took 9 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,598] INFO Tier partition state for _confluent_balancer_partition_samples-21 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,599] INFO Closing log for _confluent_balancer_partition_samples took 19 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,625] INFO Tier partition state for _confluent_balancer_partition_samples-15 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,629] INFO Closing log for _confluent_balancer_partition_samples took 30 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,647] INFO Tier partition state for _confluent_balancer_broker_samples-2 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,649] INFO Closing log for _confluent_balancer_broker_samples took 19 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,682] INFO Tier partition state for _confluent_balancer_broker_samples-22 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,688] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:36,699] INFO Closing log for _confluent_balancer_broker_samples took 50 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,731] INFO Tier partition state for __consumer_offsets-7 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,732] INFO Closing log for __consumer_offsets took 34 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,772] INFO Tier partition state for _confluent_balancer_partition_samples-9 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,773] INFO Closing log for _confluent_balancer_partition_samples took 40 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,781] INFO Tier partition state for _confluent_balancer_broker_samples-18 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,788] INFO Closing log for _confluent_balancer_broker_samples took 14 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,818] INFO Tier partition state for _confluent_balancer_partition_samples-4 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,820] INFO Closing log for _confluent_balancer_partition_samples took 31 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,866] INFO Tier partition state for _confluent_balancer_partition_samples-17 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,881] INFO Closing log for _confluent_balancer_partition_samples took 61 ms. (kafka.log.LogManager) [2021-02-17 02:25:36,926] INFO Tier partition state for __consumer_offsets-22 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:36,929] INFO Closing log for __consumer_offsets took 48 ms. (kafka.log.LogManager) [2021-02-17 02:25:37,001] INFO Tier partition state for _confluent_balancer_partition_samples-31 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:37,009] INFO Closing log for _confluent_balancer_partition_samples took 80 ms. (kafka.log.LogManager) [2021-02-17 02:25:37,056] INFO Tier partition state for _confluent_balancer_partition_samples-5 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:37,058] INFO Closing log for _confluent_balancer_partition_samples took 49 ms. (kafka.log.LogManager) [2021-02-17 02:25:37,082] INFO Tier partition state for _confluent_balancer_broker_samples-21 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:37,083] INFO Closing log for _confluent_balancer_broker_samples took 26 ms. (kafka.log.LogManager) [2021-02-17 02:25:37,115] INFO Tier partition state for __consumer_offsets-46 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:37,116] INFO Closing log for __consumer_offsets took 32 ms. (kafka.log.LogManager) [2021-02-17 02:25:37,123] INFO Tier partition state for _confluent-metrics-8 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:37,123] INFO [ProducerStateManager partition=_confluent-metrics-8] Writing producer snapshot at offset 5 (kafka.log.ProducerStateManager) [2021-02-17 02:25:37,126] INFO Closing log for _confluent-metrics took 10 ms. (kafka.log.LogManager) [2021-02-17 02:25:37,159] INFO Tier partition state for _confluent_balancer_broker_samples-11 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:37,161] INFO Closing log for _confluent_balancer_broker_samples took 35 ms. (kafka.log.LogManager) [2021-02-17 02:25:37,220] INFO Tier partition state for __consumer_offsets-31 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:37,236] INFO Closing log for __consumer_offsets took 76 ms. (kafka.log.LogManager) [2021-02-17 02:25:37,275] INFO Tier partition state for __consumer_offsets-5 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:37,278] INFO Closing log for __consumer_offsets took 41 ms. (kafka.log.LogManager) [2021-02-17 02:25:37,308] INFO Tier partition state for __consumer_offsets-2 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:37,310] INFO Closing log for __consumer_offsets took 31 ms. (kafka.log.LogManager) [2021-02-17 02:25:37,361] INFO Tier partition state for __consumer_offsets-15 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:37,363] INFO Closing log for __consumer_offsets took 52 ms. (kafka.log.LogManager) [2021-02-17 02:25:37,404] INFO Tier partition state for __consumer_offsets-34 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:37,405] INFO Closing log for __consumer_offsets took 42 ms. (kafka.log.LogManager) [2021-02-17 02:25:37,482] INFO Tier partition state for __consumer_offsets-9 closed. (kafka.tier.state.FileTierPartitionState) [2021-02-17 02:25:37,484] INFO Closing log for __consumer_offsets took 78 ms. (kafka.log.LogManager) [2021-02-17 02:25:37,577] INFO Shutdown complete. (kafka.log.LogManager) [2021-02-17 02:25:37,578] INFO [ControllerEventThread controllerId=1] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread) [2021-02-17 02:25:37,579] INFO [ControllerEventThread controllerId=1] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread) [2021-02-17 02:25:37,579] INFO [ControllerEventThread controllerId=1] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread) [2021-02-17 02:25:37,581] DEBUG [Controller id=1] Resigning (kafka.controller.KafkaController) [2021-02-17 02:25:37,582] DEBUG [Controller id=1] Unregister BrokerModifications handler for Set(1) (kafka.controller.KafkaController) [2021-02-17 02:25:37,588] INFO DataBalancer: Scheduling DataBalanceEngine Shutdown. (io.confluent.databalancer.ConfluentDataBalanceEngine) [2021-02-17 02:25:37,597] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:37,597] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:37,597] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:37,602] INFO [PartitionStateMachine controllerId=1] Stopped partition state machine (kafka.controller.ZkPartitionStateMachine) [2021-02-17 02:25:37,603] INFO App info kafka.consumer for kafka-cruise-control unregistered (org.apache.kafka.common.utils.AppInfoParser) [2021-02-17 02:25:37,603] WARN DataBalanceEngine startup aborted by shutdown. (io.confluent.databalancer.ConfluentDataBalanceEngine) io.confluent.databalancer.startup.StartupCheckInterruptedException at io.confluent.cruisecontrol.metricsreporter.ConfluentMetricsSamplerBase.checkStartupCondition(ConfluentMetricsSamplerBase.java:336) at io.confluent.databalancer.startup.StartupComponents$StartupComponent.start(StartupComponents.java:67) at io.confluent.databalancer.startup.StartupComponents.checkStartupCondition(StartupComponents.java:45) at io.confluent.databalancer.startup.CruiseControlStartable.startUp(CruiseControlStartable.java:76) at io.confluent.databalancer.ConfluentDataBalanceEngine.doStart(ConfluentDataBalanceEngine.java:425) at io.confluent.databalancer.ConfluentDataBalanceEngine.doStart(ConfluentDataBalanceEngine.java:412) at io.confluent.databalancer.ConfluentDataBalanceEngine.lambda$onActivation$3(ConfluentDataBalanceEngine.java:151) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at com.linkedin.kafka.cruisecontrol.common.KafkaCruiseControlThreadFactory.lambda$newThread$1(KafkaCruiseControlThreadFactory.java:43) at java.base/java.lang.Thread.run(Thread.java:834) [2021-02-17 02:25:37,603] INFO [ReplicaStateMachine controllerId=1] Stopped replica state machine (kafka.controller.ZkReplicaStateMachine) [2021-02-17 02:25:37,613] INFO DataBalancer is already stopped. (io.confluent.databalancer.ConfluentDataBalanceEngine) [2021-02-17 02:25:37,615] INFO [RequestSendThread controllerId=1] Shutting down (kafka.controller.RequestSendThread) [2021-02-17 02:25:37,616] INFO [RequestSendThread controllerId=1] Shutdown completed (kafka.controller.RequestSendThread) [2021-02-17 02:25:37,616] INFO [RequestSendThread controllerId=1] Stopped (kafka.controller.RequestSendThread) [2021-02-17 02:25:37,622] INFO [Controller id=1] Resigned (kafka.controller.KafkaController) [2021-02-17 02:25:37,635] INFO [feature-zk-node-event-process-thread]: Shutting down (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread) [2021-02-17 02:25:37,641] INFO [feature-zk-node-event-process-thread]: Stopped (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread) [2021-02-17 02:25:37,649] INFO [feature-zk-node-event-process-thread]: Shutdown completed (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread) [2021-02-17 02:25:37,650] INFO [ZooKeeperClient Kafka server] Closing. (kafka.zookeeper.ZooKeeperClient) [2021-02-17 02:25:37,782] INFO Session: 0x100008038660001 closed (org.apache.zookeeper.ZooKeeper) [2021-02-17 02:25:37,782] INFO EventThread shut down for session: 0x100008038660001 (org.apache.zookeeper.ClientCnxn) [2021-02-17 02:25:37,784] WARN [Producer clientId=confluent-telemetry-reporter-local-producer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:37,799] INFO [ZooKeeperClient Kafka server] Closed. (kafka.zookeeper.ZooKeeperClient) [2021-02-17 02:25:37,800] INFO [ThrottledChannelReaper-Fetch]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2021-02-17 02:25:37,808] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:38,427] INFO [ThrottledChannelReaper-Fetch]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2021-02-17 02:25:38,427] INFO [ThrottledChannelReaper-Fetch]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2021-02-17 02:25:38,428] INFO [ThrottledChannelReaper-Produce]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2021-02-17 02:25:38,839] WARN [Producer clientId=confluent-telemetry-reporter-local-producer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:38,918] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:39,417] INFO [ThrottledChannelReaper-Produce]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2021-02-17 02:25:39,417] INFO [ThrottledChannelReaper-Produce]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2021-02-17 02:25:39,418] INFO [ThrottledChannelReaper-Request]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2021-02-17 02:25:39,822] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:40,059] WARN [Producer clientId=confluent-telemetry-reporter-local-producer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:40,331] INFO [ThrottledChannelReaper-Request]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2021-02-17 02:25:40,331] INFO [ThrottledChannelReaper-Request]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2021-02-17 02:25:40,331] INFO [ThrottledChannelReaper-ControllerMutation]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2021-02-17 02:25:40,796] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:41,196] WARN [Producer clientId=confluent-telemetry-reporter-local-producer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:41,353] INFO [ThrottledChannelReaper-ControllerMutation]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2021-02-17 02:25:41,354] INFO [ThrottledChannelReaper-ControllerMutation]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2021-02-17 02:25:41,355] INFO [SocketServer brokerId=1] Shutting down socket server (kafka.network.SocketServer) [2021-02-17 02:25:41,751] WARN [Producer clientId=confluent-metrics-reporter] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:42,159] INFO [SocketServer brokerId=1] Shutdown completed (kafka.network.SocketServer) [2021-02-17 02:25:42,160] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:42,161] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:42,161] INFO Closing reporter io.confluent.metrics.reporter.ConfluentMetricsReporter (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:42,161] INFO Stopping Confluent metrics reporter (io.confluent.metrics.reporter.ConfluentMetricsReporter) [2021-02-17 02:25:42,162] INFO [Producer clientId=confluent-metrics-reporter] Closing the Kafka producer with timeoutMillis = 0 ms. (org.apache.kafka.clients.producer.KafkaProducer) [2021-02-17 02:25:42,162] INFO [Producer clientId=confluent-metrics-reporter] Proceeding to force close the producer since pending requests could not be completed within timeout 0 ms. (org.apache.kafka.clients.producer.KafkaProducer) [2021-02-17 02:25:42,209] WARN Failed to produce metrics message (io.confluent.metrics.reporter.ConfluentMetricsReporter) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:748) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:735) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:280) at java.base/java.lang.Thread.run(Thread.java:834) [2021-02-17 02:25:42,225] WARN Failed to produce metrics message (io.confluent.metrics.reporter.ConfluentMetricsReporter) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:748) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:735) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:280) at java.base/java.lang.Thread.run(Thread.java:834) [2021-02-17 02:25:42,225] WARN Failed to produce metrics message (io.confluent.metrics.reporter.ConfluentMetricsReporter) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:748) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:735) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:280) at java.base/java.lang.Thread.run(Thread.java:834) [2021-02-17 02:25:42,225] WARN Failed to produce metrics message (io.confluent.metrics.reporter.ConfluentMetricsReporter) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:748) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:735) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:280) at java.base/java.lang.Thread.run(Thread.java:834) [2021-02-17 02:25:42,225] WARN Failed to produce metrics message (io.confluent.metrics.reporter.ConfluentMetricsReporter) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:748) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:735) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:280) at java.base/java.lang.Thread.run(Thread.java:834) [2021-02-17 02:25:42,226] WARN Failed to produce metrics message (io.confluent.metrics.reporter.ConfluentMetricsReporter) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:748) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:735) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:280) at java.base/java.lang.Thread.run(Thread.java:834) [2021-02-17 02:25:42,226] WARN Failed to produce metrics message (io.confluent.metrics.reporter.ConfluentMetricsReporter) org.apache.kafka.common.KafkaException: Producer is closed forcefully. at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:748) at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:735) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:280) at java.base/java.lang.Thread.run(Thread.java:834) [2021-02-17 02:25:42,231] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:42,231] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:42,232] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:42,232] INFO App info kafka.producer for confluent-metrics-reporter unregistered (org.apache.kafka.common.utils.AppInfoParser) [2021-02-17 02:25:42,232] INFO Closing reporter io.confluent.telemetry.reporter.TelemetryReporter (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:42,233] INFO Stopping TelemetryReporter collectorTask (io.confluent.telemetry.reporter.TelemetryReporter) [2021-02-17 02:25:42,247] INFO [Producer clientId=confluent-telemetry-reporter-local-producer] Closing the Kafka producer with timeoutMillis = 0 ms. (org.apache.kafka.clients.producer.KafkaProducer) [2021-02-17 02:25:42,248] INFO [Producer clientId=confluent-telemetry-reporter-local-producer] Proceeding to force close the producer since pending requests could not be completed within timeout 0 ms. (org.apache.kafka.clients.producer.KafkaProducer) [2021-02-17 02:25:42,264] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:42,264] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:42,265] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:42,265] INFO App info kafka.producer for confluent-telemetry-reporter-local-producer unregistered (org.apache.kafka.common.utils.AppInfoParser) [2021-02-17 02:25:42,265] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2021-02-17 02:25:42,271] WARN [Producer clientId=ConfluentBalancerSampleStoreProducer] Connection to node 1 (broker/172.22.0.3:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2021-02-17 02:25:42,302] INFO Broker and topic stats closed (kafka.server.BrokerTopicStats) [2021-02-17 02:25:42,303] INFO App info kafka.server for 1 unregistered (org.apache.kafka.common.utils.AppInfoParser) [2021-02-17 02:25:42,303] INFO [KafkaServer id=1] shut down completed (kafka.server.KafkaServer) [2021-02-17 02:25:42,304] ERROR Exiting Kafka. (kafka.server.KafkaServerStartable) [2021-02-17 02:25:42,336] INFO [KafkaServer id=1] shutting down (kafka.server.KafkaServer)