Removed Kafka

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