-
kafka 命令行使用 消息的写入和读取 quickstart
Intro
Kafka在大型系统中可用作消息通道，一般是用程序语言作为客户端去调用kafka服务。
不过在这之前，可以先用下载kafka之后就包含的脚本文件等，测试一下如下操作：- 启动 zookeeper 服务
- 启动 kafka 服务
- 创建新的 topic
- producer 向指定的 topic 写入数据
- consumer 从指定的 topic 读取数据
以下操作，参考 https://kafka.apache.org/quickstart
命令
# 先进入一个你喜欢的目录，等会会在这个目录中下载 Kafka 压缩包 cd ~/Programs # 下载、解压、进入目录 wget -c https://dlcdn.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz tar -xzf kafka_2.13-3.7.0.tgz cd kafka_2.13-3.7.0.tgz ## 【注意，以下几步操作中，1、2、4、5都需要单独开一个窗口运行。】 # 1. 启动自带的 zookeeper 服务器 bin/zookeeper-server-start.sh config/zookeeper.properties # 2. 启动 kafka 服务器 bin/kafka-server-start.sh config/server.properties # 3. 创建 topic ，然后查看 topic 的描述 bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --topic wuyujin1997_topic_01 bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic wuyujin1997_topic_01 # 4. consumer 消费者——订阅/读取消息 （读取窗口单独放着，等着观察就好了） bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic wuyujin1997_topic_01 --from-beginning # 5. producer 生产者——发布/写入消息 bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic wuyujin1997_topic_01 > aaa > bbb > hello 于禁 # 可以看到，当使用 kafka-console-producer.sh 每写入新的一行数据时， consumer 窗口就会接收到心的消息行。- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
日志
zookeeper server
wuyujin1997@wyjmacm1 kafka_2.13-3.7.0 % bin/zookeeper-server-start.sh config/zookeeper.properties [2024-04-22 23:46:10,879] INFO Reading configuration from: config/zookeeper.properties (org.apache.zookeeper.server.quorum.QuorumPeerConfig) [2024-04-22 23:46:10,880] WARN config/zookeeper.properties is relative. Prepend ./ to indicate that you're sure! (org.apache.zookeeper.server.quorum.QuorumPeerConfig) [2024-04-22 23:46:10,895] INFO clientPortAddress is 0.0.0.0:2181 (org.apache.zookeeper.server.quorum.QuorumPeerConfig) [2024-04-22 23:46:10,895] INFO secureClientPort is not set (org.apache.zookeeper.server.quorum.QuorumPeerConfig) [2024-04-22 23:46:10,895] INFO observerMasterPort is not set (org.apache.zookeeper.server.quorum.QuorumPeerConfig) [2024-04-22 23:46:10,895] INFO metricsProvider.className is org.apache.zookeeper.metrics.impl.DefaultMetricsProvider (org.apache.zookeeper.server.quorum.QuorumPeerConfig) [2024-04-22 23:46:10,897] INFO autopurge.snapRetainCount set to 3 (org.apache.zookeeper.server.DatadirCleanupManager) [2024-04-22 23:46:10,898] INFO autopurge.purgeInterval set to 0 (org.apache.zookeeper.server.DatadirCleanupManager) [2024-04-22 23:46:10,898] INFO Purge task is not scheduled. (org.apache.zookeeper.server.DatadirCleanupManager) [2024-04-22 23:46:10,898] WARN Either no config or no quorum defined in config, running in standalone mode (org.apache.zookeeper.server.quorum.QuorumPeerMain) [2024-04-22 23:46:10,899] INFO Log4j 1.2 jmx support not found; jmx disabled. (org.apache.zookeeper.jmx.ManagedUtil) [2024-04-22 23:46:10,899] INFO Reading configuration from: config/zookeeper.properties (org.apache.zookeeper.server.quorum.QuorumPeerConfig) [2024-04-22 23:46:10,899] WARN config/zookeeper.properties is relative. Prepend ./ to indicate that you're sure! (org.apache.zookeeper.server.quorum.QuorumPeerConfig) [2024-04-22 23:46:10,901] INFO clientPortAddress is 0.0.0.0:2181 (org.apache.zookeeper.server.quorum.QuorumPeerConfig) [2024-04-22 23:46:10,901] INFO secureClientPort is not set (org.apache.zookeeper.server.quorum.QuorumPeerConfig) [2024-04-22 23:46:10,901] INFO observerMasterPort is not set (org.apache.zookeeper.server.quorum.QuorumPeerConfig) [2024-04-22 23:46:10,901] INFO metricsProvider.className is org.apache.zookeeper.metrics.impl.DefaultMetricsProvider (org.apache.zookeeper.server.quorum.QuorumPeerConfig) [2024-04-22 23:46:10,901] INFO Starting server (org.apache.zookeeper.server.ZooKeeperServerMain) [2024-04-22 23:46:10,927] INFO ServerMetrics initialized with provider org.apache.zookeeper.metrics.impl.DefaultMetricsProvider@3e6ef8ad (org.apache.zookeeper.server.ServerMetrics) [2024-04-22 23:46:10,931] INFO ACL digest algorithm is: SHA1 (org.apache.zookeeper.server.auth.DigestAuthenticationProvider) [2024-04-22 23:46:10,931] INFO zookeeper.DigestAuthenticationProvider.enabled = true (org.apache.zookeeper.server.auth.DigestAuthenticationProvider) [2024-04-22 23:46:10,935] INFO zookeeper.snapshot.trust.empty : false (org.apache.zookeeper.server.persistence.FileTxnSnapLog) [2024-04-22 23:46:10,946] INFO (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,946] INFO ______ _ (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,946] INFO |___ / | | (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,946] INFO / / ___ ___ | | __ ___ ___ _ __ ___ _ __ (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,946] INFO / / / _ \ / _ \ | |/ / / _ \ / _ \ | '_ \ / _ \ | '__| (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,946] INFO / /__ | (_) | | (_) | | < | __/ | __/ | |_) | | __/ | | (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,946] INFO /_____| \___/ \___/ |_|\_\ \___| \___| | .__/ \___| |_| (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,946] INFO | | (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,946] INFO |_| (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,946] INFO (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,948] INFO Server environment:zookeeper.version=3.8.3-6ad6d364c7c0bcf0de452d54ebefa3058098ab56, built on 2023-10-05 10:34 UTC (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,949] INFO Server environment:host.name=localhost (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,949] INFO Server environment:java.version=11.0.1 (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,949] INFO Server environment:java.vendor=Oracle Corporation (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,949] INFO Server environment:java.home=/Library/Java/JavaVirtualMachines/jdk-11.0.1.jdk/Contents/Home (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,949] INFO Server environment:java.class.path=/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/activation-1.1.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/aopalliance-repackaged-2.6.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/argparse4j-0.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/audience-annotations-0.12.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/caffeine-2.9.3.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/checker-qual-3.19.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-beanutils-1.9.4.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-cli-1.4.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-collections-3.2.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-digester-2.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-io-2.11.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-lang3-3.8.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-logging-1.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-validator-1.7.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/connect-api-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/connect-basic-auth-extension-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/connect-json-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/connect-mirror-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/connect-mirror-client-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/connect-runtime-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/connect-transforms-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/error_prone_annotations-2.10.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/hk2-api-2.6.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/hk2-locator-2.6.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/hk2-utils-2.6.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-annotations-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-core-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-databind-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-dataformat-csv-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-datatype-jdk8-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-jaxrs-base-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-jaxrs-json-provider-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-module-jaxb-annotations-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-module-scala_2.13-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jakarta.activation-api-1.2.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jakarta.annotation-api-1.3.5.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jakarta.inject-2.6.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jakarta.validation-api-2.0.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jakarta.ws.rs-api-2.1.6.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jakarta.xml.bind-api-2.3.3.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/javassist-3.29.2-GA.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/javax.activation-api-1.2.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/javax.annotation-api-1.3.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/javax.servlet-api-3.1.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/javax.ws.rs-api-2.1.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jaxb-api-2.3.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jersey-client-2.39.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jersey-common-2.39.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jersey-container-servlet-2.39.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jersey-container-servlet-core-2.39.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jersey-hk2-2.39.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jersey-server-2.39.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-client-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-continuation-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-http-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-io-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-security-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-server-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-servlet-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-servlets-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-util-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-util-ajax-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jline-3.22.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jopt-simple-5.0.4.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jose4j-0.9.4.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jsr305-3.0.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-clients-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-group-coordinator-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-log4j-appender-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-metadata-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-raft-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-server-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-server-common-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-shell-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-storage-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-storage-api-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-streams-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-streams-examples-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-streams-scala_2.13-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-streams-test-utils-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-tools-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-tools-api-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka_2.13-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/lz4-java-1.8.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/maven-artifact-3.8.8.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/metrics-core-2.2.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/metrics-core-4.1.12.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-buffer-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-codec-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-common-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-handler-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-resolver-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-transport-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-transport-classes-epoll-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-transport-native-epoll-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-transport-native-unix-common-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/opentelemetry-proto-1.0.0-alpha.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/osgi-resource-locator-1.0.3.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/paranamer-2.8.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/pcollections-4.0.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/plexus-utils-3.3.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/protobuf-java-3.23.4.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/reflections-0.10.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/reload4j-1.2.25.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/rocksdbjni-7.9.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/scala-collection-compat_2.13-2.10.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/scala-java8-compat_2.13-1.0.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/scala-library-2.13.12.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/scala-logging_2.13-3.9.4.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/scala-reflect-2.13.12.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/slf4j-api-1.7.36.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/slf4j-reload4j-1.7.36.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/snappy-java-1.1.10.5.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/swagger-annotations-2.2.8.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/trogdor-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/zookeeper-3.8.3.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/zookeeper-jute-3.8.3.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/zstd-jni-1.5.5-6.jar (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,949] INFO Server environment:java.library.path=/Users/wuyujin1997/Library/Java/Extensions:/Library/Java/Extensions:/Network/Library/Java/Extensions:/System/Library/Java/Extensions:/usr/lib/java:. (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,949] INFO Server environment:java.io.tmpdir=/var/folders/dx/lf5ftc_s2jv0048wny6vsl200000gp/T/ (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,950] INFO Server environment:java.compiler=(org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,950] INFO Server environment:os.name=Mac OS X (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,950] INFO Server environment:os.arch=x86_64 (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,950] INFO Server environment:os.version=10.16 (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,950] INFO Server environment:user.name=wuyujin1997 (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,950] INFO Server environment:user.home=/Users/wuyujin1997 (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,950] INFO Server environment:user.dir=/Users/wuyujin1997/Programs/kafka_2.13-3.7.0 (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,950] INFO Server environment:os.memory.free=487MB (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,950] INFO Server environment:os.memory.max=512MB (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,950] INFO Server environment:os.memory.total=512MB (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,950] INFO zookeeper.enableEagerACLCheck = false (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,950] INFO zookeeper.digest.enabled = true (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,950] INFO zookeeper.closeSessionTxn.enabled = true (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,951] INFO zookeeper.flushDelay = 0 ms (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,951] INFO zookeeper.maxWriteQueuePollTime = 0 ms (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,951] INFO zookeeper.maxBatchSize=1000 (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,951] INFO zookeeper.intBufferStartingSizeBytes = 1024 (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,952] INFO Weighed connection throttling is disabled (org.apache.zookeeper.server.BlueThrottle) [2024-04-22 23:46:10,955] INFO minSessionTimeout set to 6000 ms (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,955] INFO maxSessionTimeout set to 60000 ms (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,957] INFO getData response cache size is initialized with value 400. (org.apache.zookeeper.server.ResponseCache) [2024-04-22 23:46:10,958] INFO getChildren response cache size is initialized with value 400. (org.apache.zookeeper.server.ResponseCache) [2024-04-22 23:46:10,977] INFO zookeeper.pathStats.slotCapacity = 60 (org.apache.zookeeper.server.util.RequestPathMetricsCollector) [2024-04-22 23:46:10,977] INFO zookeeper.pathStats.slotDuration = 15 (org.apache.zookeeper.server.util.RequestPathMetricsCollector) [2024-04-22 23:46:10,977] INFO zookeeper.pathStats.maxDepth = 6 (org.apache.zookeeper.server.util.RequestPathMetricsCollector) [2024-04-22 23:46:10,977] INFO zookeeper.pathStats.initialDelay = 5 (org.apache.zookeeper.server.util.RequestPathMetricsCollector) [2024-04-22 23:46:10,977] INFO zookeeper.pathStats.delay = 5 (org.apache.zookeeper.server.util.RequestPathMetricsCollector) [2024-04-22 23:46:10,977] INFO zookeeper.pathStats.enabled = false (org.apache.zookeeper.server.util.RequestPathMetricsCollector) [2024-04-22 23:46:10,984] INFO The max bytes for all large requests are set to 104857600 (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,985] INFO The large request threshold is set to -1 (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:10,986] INFO zookeeper.enforce.auth.enabled = false (org.apache.zookeeper.server.AuthenticationHelper) [2024-04-22 23:46:10,986] INFO zookeeper.enforce.auth.schemes = [] (org.apache.zookeeper.server.AuthenticationHelper) [2024-04-22 23:46:10,986] INFO Created server with tickTime 3000 ms minSessionTimeout 6000 ms maxSessionTimeout 60000 ms clientPortListenBacklog -1 datadir /tmp/zookeeper/version-2 snapdir /tmp/zookeeper/version-2 (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:11,003] INFO Using org.apache.zookeeper.server.NIOServerCnxnFactory as server connection factory (org.apache.zookeeper.server.ServerCnxnFactory) [2024-04-22 23:46:11,005] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory) [2024-04-22 23:46:11,009] 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) [2024-04-22 23:46:11,021] INFO binding to port 0.0.0.0/0.0.0.0:2181 (org.apache.zookeeper.server.NIOServerCnxnFactory) [2024-04-22 23:46:11,039] INFO Using org.apache.zookeeper.server.watch.WatchManager as watch manager (org.apache.zookeeper.server.watch.WatchManagerFactory) [2024-04-22 23:46:11,039] INFO Using org.apache.zookeeper.server.watch.WatchManager as watch manager (org.apache.zookeeper.server.watch.WatchManagerFactory) [2024-04-22 23:46:11,041] INFO zookeeper.snapshotSizeFactor = 0.33 (org.apache.zookeeper.server.ZKDatabase) [2024-04-22 23:46:11,041] INFO zookeeper.commitLogCount=500 (org.apache.zookeeper.server.ZKDatabase) [2024-04-22 23:46:11,046] INFO zookeeper.snapshot.compression.method = CHECKED (org.apache.zookeeper.server.persistence.SnapStream) [2024-04-22 23:46:11,047] INFO Reading snapshot /tmp/zookeeper/version-2/snapshot.93 (org.apache.zookeeper.server.persistence.FileSnap) [2024-04-22 23:46:11,063] INFO The digest in the snapshot has digest version of 2, with zxid as 0x93, and digest value as 317817286343 (org.apache.zookeeper.server.DataTree) [2024-04-22 23:46:11,106] INFO ZooKeeper audit is disabled. (org.apache.zookeeper.audit.ZKAuditProvider) [2024-04-22 23:46:11,106] INFO 32 txns loaded in 19 ms (org.apache.zookeeper.server.persistence.FileTxnSnapLog) [2024-04-22 23:46:11,106] INFO Snapshot loaded in 65 ms, highest zxid is 0xb3, digest is 341218451456 (org.apache.zookeeper.server.ZKDatabase) [2024-04-22 23:46:11,108] INFO Snapshotting: 0xb3 to /tmp/zookeeper/version-2/snapshot.b3 (org.apache.zookeeper.server.persistence.FileTxnSnapLog) [2024-04-22 23:46:11,114] INFO Snapshot taken in 6 ms (org.apache.zookeeper.server.ZooKeeperServer) [2024-04-22 23:46:11,125] INFO zookeeper.request_throttler.shutdownTimeout = 10000 ms (org.apache.zookeeper.server.RequestThrottler) [2024-04-22 23:46:11,125] INFO PrepRequestProcessor (sid:0) started, reconfigEnabled=false (org.apache.zookeeper.server.PrepRequestProcessor) [2024-04-22 23:46:11,161] INFO Using checkIntervalMs=60000 maxPerMinute=10000 maxNeverUsedIntervalMs=0 (org.apache.zookeeper.server.ContainerManager) [2024-04-22 23:46:27,019] INFO Creating new log file: log.b4 (org.apache.zookeeper.server.persistence.FileTxnLog) - 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
- 71
- 72
- 73
- 74
- 75
- 76
- 77
- 78
- 79
- 80
- 81
- 82
- 83
- 84
- 85
- 86
- 87
- 88
- 89
- 90
- 91
- 92
- 93
- 94
- 95
- 96
- 97
- 98
kafka server
wuyujin1997@wyjmacm1 kafka_2.13-3.7.0 % bin/kafka-server-start.sh config/server.properties [2024-04-22 23:55:11,604] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$) [2024-04-22 23:55:12,045] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util) [2024-04-22 23:55:12,162] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler) [2024-04-22 23:55:12,164] INFO starting (kafka.server.KafkaServer) [2024-04-22 23:55:12,164] INFO Connecting to zookeeper on localhost:2181 (kafka.server.KafkaServer) [2024-04-22 23:55:12,178] INFO [ZooKeeperClient Kafka server] Initializing a new session to localhost:2181. (kafka.zookeeper.ZooKeeperClient) [2024-04-22 23:55:12,185] INFO Client environment:zookeeper.version=3.8.3-6ad6d364c7c0bcf0de452d54ebefa3058098ab56, built on 2023-10-05 10:34 UTC (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,185] INFO Client environment:host.name=localhost (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,185] INFO Client environment:java.version=11.0.1 (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,185] INFO Client environment:java.vendor=Oracle Corporation (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,185] INFO Client environment:java.home=/Library/Java/JavaVirtualMachines/jdk-11.0.1.jdk/Contents/Home (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,185] INFO Client environment:java.class.path=/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/activation-1.1.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/aopalliance-repackaged-2.6.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/argparse4j-0.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/audience-annotations-0.12.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/caffeine-2.9.3.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/checker-qual-3.19.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-beanutils-1.9.4.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-cli-1.4.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-collections-3.2.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-digester-2.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-io-2.11.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-lang3-3.8.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-logging-1.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/commons-validator-1.7.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/connect-api-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/connect-basic-auth-extension-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/connect-json-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/connect-mirror-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/connect-mirror-client-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/connect-runtime-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/connect-transforms-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/error_prone_annotations-2.10.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/hk2-api-2.6.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/hk2-locator-2.6.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/hk2-utils-2.6.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-annotations-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-core-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-databind-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-dataformat-csv-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-datatype-jdk8-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-jaxrs-base-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-jaxrs-json-provider-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-module-jaxb-annotations-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jackson-module-scala_2.13-2.16.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jakarta.activation-api-1.2.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jakarta.annotation-api-1.3.5.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jakarta.inject-2.6.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jakarta.validation-api-2.0.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jakarta.ws.rs-api-2.1.6.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jakarta.xml.bind-api-2.3.3.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/javassist-3.29.2-GA.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/javax.activation-api-1.2.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/javax.annotation-api-1.3.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/javax.servlet-api-3.1.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/javax.ws.rs-api-2.1.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jaxb-api-2.3.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jersey-client-2.39.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jersey-common-2.39.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jersey-container-servlet-2.39.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jersey-container-servlet-core-2.39.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jersey-hk2-2.39.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jersey-server-2.39.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-client-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-continuation-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-http-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-io-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-security-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-server-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-servlet-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-servlets-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-util-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jetty-util-ajax-9.4.53.v20231009.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jline-3.22.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jopt-simple-5.0.4.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jose4j-0.9.4.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/jsr305-3.0.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-clients-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-group-coordinator-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-log4j-appender-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-metadata-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-raft-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-server-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-server-common-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-shell-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-storage-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-storage-api-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-streams-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-streams-examples-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-streams-scala_2.13-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-streams-test-utils-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-tools-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka-tools-api-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/kafka_2.13-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/lz4-java-1.8.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/maven-artifact-3.8.8.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/metrics-core-2.2.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/metrics-core-4.1.12.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-buffer-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-codec-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-common-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-handler-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-resolver-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-transport-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-transport-classes-epoll-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-transport-native-epoll-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/netty-transport-native-unix-common-4.1.100.Final.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/opentelemetry-proto-1.0.0-alpha.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/osgi-resource-locator-1.0.3.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/paranamer-2.8.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/pcollections-4.0.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/plexus-utils-3.3.1.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/protobuf-java-3.23.4.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/reflections-0.10.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/reload4j-1.2.25.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/rocksdbjni-7.9.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/scala-collection-compat_2.13-2.10.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/scala-java8-compat_2.13-1.0.2.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/scala-library-2.13.12.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/scala-logging_2.13-3.9.4.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/scala-reflect-2.13.12.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/slf4j-api-1.7.36.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/slf4j-reload4j-1.7.36.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/snappy-java-1.1.10.5.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/swagger-annotations-2.2.8.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/trogdor-3.7.0.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/zookeeper-3.8.3.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/zookeeper-jute-3.8.3.jar:/Users/wuyujin1997/Programs/kafka_2.13-3.7.0/bin/../libs/zstd-jni-1.5.5-6.jar (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,186] INFO Client environment:java.library.path=/Users/wuyujin1997/Library/Java/Extensions:/Library/Java/Extensions:/Network/Library/Java/Extensions:/System/Library/Java/Extensions:/usr/lib/java:. (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,186] INFO Client environment:java.io.tmpdir=/var/folders/dx/lf5ftc_s2jv0048wny6vsl200000gp/T/ (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,186] INFO Client environment:java.compiler=<NA> (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,186] INFO Client environment:os.name=Mac OS X (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,186] INFO Client environment:os.arch=x86_64 (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,186] INFO Client environment:os.version=10.16 (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,186] INFO Client environment:user.name=wuyujin1997 (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,186] INFO Client environment:user.home=/Users/wuyujin1997 (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,186] INFO Client environment:user.dir=/Users/wuyujin1997/Programs/kafka_2.13-3.7.0 (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,186] INFO Client environment:os.memory.free=1006MB (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,186] INFO Client environment:os.memory.max=1024MB (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,186] INFO Client environment:os.memory.total=1024MB (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,188] INFO Initiating client connection, connectString=localhost:2181 sessionTimeout=18000 watcher=kafka.zookeeper.ZooKeeperClient$ZooKeeperClientWatcher$@59252cb6 (org.apache.zookeeper.ZooKeeper) [2024-04-22 23:55:12,194] INFO jute.maxbuffer value is 4194304 Bytes (org.apache.zookeeper.ClientCnxnSocket) [2024-04-22 23:55:12,205] INFO zookeeper.request.timeout value is 0. feature enabled=false (org.apache.zookeeper.ClientCnxn) [2024-04-22 23:55:12,211] INFO [ZooKeeperClient Kafka server] Waiting until connected. (kafka.zookeeper.ZooKeeperClient) [2024-04-22 23:55:12,217] INFO Opening socket connection to server localhost/127.0.0.1:2181. (org.apache.zookeeper.ClientCnxn) [2024-04-22 23:55:12,236] INFO Socket connection established, initiating session, client: /127.0.0.1:58018, server: localhost/127.0.0.1:2181 (org.apache.zookeeper.ClientCnxn) [2024-04-22 23:55:12,261] INFO Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x1000e213f930001, negotiated timeout = 18000 (org.apache.zookeeper.ClientCnxn) [2024-04-22 23:55:12,273] INFO [ZooKeeperClient Kafka server] Connected. (kafka.zookeeper.ZooKeeperClient) [2024-04-22 23:55:12,547] INFO Cluster ID = 4EH8CDNKQiKb10XVvwHCmw (kafka.server.KafkaServer) [2024-04-22 23:55:12,628] 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.include.jmx.reporter = 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 early.start.listeners = null eligible.leader.replicas.enable = false fetch.max.bytes = 57671680 fetch.purgatory.purge.interval.requests = 1000 group.consumer.assignors = [org.apache.kafka.coordinator.group.assignor.UniformAssignor, org.apache.kafka.coordinator.group.assignor.RangeAssignor] group.consumer.heartbeat.interval.ms = 5000 group.consumer.max.heartbeat.interval.ms = 15000 group.consumer.max.session.timeout.ms = 60000 group.consumer.max.size = 2147483647 group.consumer.min.heartbeat.interval.ms = 5000 group.consumer.min.session.timeout.ms = 45000 group.consumer.session.timeout.ms = 45000 group.coordinator.new.enable = false group.coordinator.rebalance.protocols = [classic] group.coordinator.threads = 1 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.7-IV4 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.local.retention.bytes = -2 log.local.retention.ms = -2 log.message.downconversion.enable = true log.message.format.version = 3.0-IV1 log.message.timestamp.after.max.ms = 9223372036854775807 log.message.timestamp.before.max.ms = 9223372036854775807 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.max.snapshot.interval.ms = 3600000 metadata.log.segment.bytes = 1073741824 metadata.log.segment.min.bytes = 8388608 metadata.log.segment.ms = 604800000 metadata.max.idle.interval.ms = 500 metadata.max.retention.bytes = 104857600 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 = 0 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.id.expiration.check.interval.ms = 600000 producer.id.expiration.ms = 86400000 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.custom.metadata.max.bytes = 128 remote.log.metadata.manager.class.name = org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager remote.log.metadata.manager.class.path = null remote.log.metadata.manager.impl.prefix = rlmm.config. 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 = rsm.config. 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism.controller.protocol = GSSAPI sasl.mechanism.inter.broker.protocol = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null sasl.server.callback.handler.class = null sasl.server.max.receive.size = 524288 security.inter.broker.protocol = PLAINTEXT security.providers = null server.max.startup.time.ms = 9223372036854775807 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 socket.listen.backlog.size = 50 socket.receive.buffer.bytes = 102400 socket.request.max.bytes = 104857600 socket.send.buffer.bytes = 102400 ssl.allow.dn.changes = false ssl.allow.san.changes = false 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 telemetry.max.bytes = 1048576 transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000 transaction.max.timeout.ms = 900000 transaction.partition.verification.enable = true 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 unstable.api.versions.enable = false unstable.metadata.versions.enable = false zookeeper.clientCnxnSocket = null zookeeper.connect = localhost:2181 zookeeper.connection.timeout.ms = 18000 zookeeper.max.in.flight.requests = 10 zookeeper.metadata.migration.enable = false zookeeper.metadata.migration.min.batch.size = 200 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 (kafka.server.KafkaConfig) [2024-04-22 23:46:27,480] INFO [ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2024-04-22 23:46:27,482] INFO [ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2024-04-22 23:46:27,486] INFO [ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2024-04-22 23:46:27,489] INFO [ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2024-04-22 23:46:27,551] INFO Loading logs from log dirs ArraySeq(/tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,569] INFO Skipping recovery of 54 logs from /tmp/kafka-logs since clean shutdown file was found (kafka.log.LogManager) [2024-04-22 23:46:27,702] INFO [LogLoader partition=__consumer_offsets-9, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,733] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-9, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=9, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 122ms (1/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,742] INFO [LogLoader partition=__consumer_offsets-0, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,744] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-0, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 11ms (2/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,749] INFO [LogLoader partition=__consumer_offsets-7, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,752] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-7, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=7, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 8ms (3/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,760] INFO [LogLoader partition=__consumer_offsets-31, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,763] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-31, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=31, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 10ms (4/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,768] INFO [LogLoader partition=__consumer_offsets-36, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,772] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-36, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=36, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 8ms (5/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,776] INFO [LogLoader partition=yujin_topic_02-0, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,780] INFO Completed load of Log(dir=/tmp/kafka-logs/yujin_topic_02-0, topicId=KxIG75ngR_egw0tHmae7Yw, topic=yujin_topic_02, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 8ms (6/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,784] INFO [LogLoader partition=__consumer_offsets-38, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,788] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-38, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=38, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 7ms (7/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,795] INFO [LogLoader partition=__consumer_offsets-6, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,797] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-6, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=6, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 9ms (8/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,801] INFO [LogLoader partition=__consumer_offsets-1, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,803] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-1, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=1, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 6ms (9/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,811] INFO [LogLoader partition=__consumer_offsets-8, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,814] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-8, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=8, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 10ms (10/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,817] INFO [LogLoader partition=__consumer_offsets-39, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,819] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-39, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=39, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 6ms (11/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,822] INFO [LogLoader partition=__consumer_offsets-37, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,823] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-37, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=37, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 4ms (12/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,827] INFO [LogLoader partition=__consumer_offsets-30, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,828] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-30, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=30, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 5ms (13/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,838] INFO [LogLoader partition=yujin_topic_01-0, dir=/tmp/kafka-logs] Loading producer state till offset 5 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,838] INFO [LogLoader partition=yujin_topic_01-0, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 5 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,838] INFO [ProducerStateManager partition=yujin_topic_01-0] Loading producer state from snapshot file 'SnapshotFile(offset=5, file=/tmp/kafka-logs/yujin_topic_01-0/00000000000000000005.snapshot)' (org.apache.kafka.storage.internals.log.ProducerStateManager) [2024-04-22 23:46:27,855] INFO [LogLoader partition=yujin_topic_01-0, dir=/tmp/kafka-logs] Producer state recovery took 17ms for snapshot load and 0ms for segment recovery from offset 5 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,859] INFO Completed load of Log(dir=/tmp/kafka-logs/yujin_topic_01-0, topicId=X-RerF6AQjyxktjmrbtemg, topic=yujin_topic_01, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=5) with 1 segments, local-log-start-offset 0 and log-end-offset 5 in 30ms (14/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,866] INFO [LogLoader partition=__consumer_offsets-12, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,868] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-12, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=12, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 8ms (15/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,874] INFO [LogLoader partition=__consumer_offsets-15, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,875] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-15, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=15, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 8ms (16/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,881] INFO [LogLoader partition=__consumer_offsets-23, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,885] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-23, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=23, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 9ms (17/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,887] INFO [LogLoader partition=__consumer_offsets-24, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,888] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-24, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=24, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 4ms (18/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,890] INFO [LogLoader partition=__consumer_offsets-48, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,892] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-48, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=48, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 3ms (19/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,895] INFO [LogLoader partition=__consumer_offsets-41, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,897] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-41, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=41, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 6ms (20/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,905] INFO [LogLoader partition=__consumer_offsets-46, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,907] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-46, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=46, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 10ms (21/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,910] INFO [LogLoader partition=__consumer_offsets-25, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,913] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-25, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=25, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 6ms (22/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,915] INFO [LogLoader partition=__consumer_offsets-22, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,918] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-22, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=22, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 4ms (23/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,923] INFO [LogLoader partition=__consumer_offsets-14, dir=/tmp/kafka-logs] Loading producer state till offset 3 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,923] INFO [LogLoader partition=__consumer_offsets-14, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 3 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,924] INFO [ProducerStateManager partition=__consumer_offsets-14] Loading producer state from snapshot file 'SnapshotFile(offset=3, file=/tmp/kafka-logs/__consumer_offsets-14/00000000000000000003.snapshot)' (org.apache.kafka.storage.internals.log.ProducerStateManager) [2024-04-22 23:46:27,924] INFO [LogLoader partition=__consumer_offsets-14, dir=/tmp/kafka-logs] Producer state recovery took 1ms for snapshot load and 0ms for segment recovery from offset 3 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,925] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-14, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=14, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=3) with 1 segments, local-log-start-offset 0 and log-end-offset 3 in 8ms (24/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,927] INFO [LogLoader partition=__consumer_offsets-13, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,928] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-13, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=13, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 3ms (25/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,932] INFO [LogLoader partition=__consumer_offsets-47, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,934] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-47, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=47, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 6ms (26/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,937] INFO [LogLoader partition=__consumer_offsets-40, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,938] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-40, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=40, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 3ms (27/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,940] INFO [LogLoader partition=__consumer_offsets-49, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,942] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-49, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=49, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 4ms (28/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,944] INFO [LogLoader partition=__consumer_offsets-35, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,947] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-35, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=35, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 5ms (29/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,951] INFO Deleted producer state snapshot /tmp/kafka-logs/__consumer_offsets-32/00000000000000000001.snapshot (org.apache.kafka.storage.internals.log.SnapshotFile) [2024-04-22 23:46:27,952] INFO [LogLoader partition=__consumer_offsets-32, dir=/tmp/kafka-logs] Loading producer state till offset 3 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,953] INFO [LogLoader partition=__consumer_offsets-32, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 3 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,953] INFO [ProducerStateManager partition=__consumer_offsets-32] Loading producer state from snapshot file 'SnapshotFile(offset=3, file=/tmp/kafka-logs/__consumer_offsets-32/00000000000000000003.snapshot)' (org.apache.kafka.storage.internals.log.ProducerStateManager) [2024-04-22 23:46:27,953] INFO [LogLoader partition=__consumer_offsets-32, dir=/tmp/kafka-logs] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 3 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,955] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-32, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=32, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=3) with 1 segments, local-log-start-offset 0 and log-end-offset 3 in 7ms (30/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,957] INFO [LogLoader partition=__consumer_offsets-4, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,958] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-4, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=4, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 4ms (31/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,964] INFO [LogLoader partition=__consumer_offsets-3, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,971] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-3, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=3, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 12ms (32/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,977] INFO [LogLoader partition=__consumer_offsets-33, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,979] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-33, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=33, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 8ms (33/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,982] INFO [LogLoader partition=__consumer_offsets-34, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,984] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-34, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=34, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 4ms (34/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,986] INFO [LogLoader partition=__consumer_offsets-2, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,986] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-2, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=2, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 3ms (35/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,991] INFO [LogLoader partition=__consumer_offsets-5, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,992] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-5, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=5, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 6ms (36/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:27,997] INFO [LogLoader partition=yujin_topic_1-0, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:27,998] INFO Completed load of Log(dir=/tmp/kafka-logs/yujin_topic_1-0, topicId=zXos2-xZTVOjQl7S83J2AQ, topic=yujin_topic_1, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 6ms (37/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,006] INFO [LogLoader partition=quickstart-events-0, dir=/tmp/kafka-logs] Loading producer state till offset 5 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,006] INFO [LogLoader partition=quickstart-events-0, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 5 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,006] INFO [ProducerStateManager partition=quickstart-events-0] Loading producer state from snapshot file 'SnapshotFile(offset=5, file=/tmp/kafka-logs/quickstart-events-0/00000000000000000005.snapshot)' (org.apache.kafka.storage.internals.log.ProducerStateManager) [2024-04-22 23:46:28,007] INFO [LogLoader partition=quickstart-events-0, dir=/tmp/kafka-logs] Producer state recovery took 1ms for snapshot load and 0ms for segment recovery from offset 5 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,012] INFO Completed load of Log(dir=/tmp/kafka-logs/quickstart-events-0, topicId=fWxKAoGFQsmHthaOALjThw, topic=quickstart-events, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=5) with 1 segments, local-log-start-offset 0 and log-end-offset 5 in 13ms (38/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,015] INFO [LogLoader partition=__consumer_offsets-45, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,016] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-45, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=45, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 4ms (39/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,019] INFO [LogLoader partition=__consumer_offsets-42, dir=/tmp/kafka-logs] Loading producer state till offset 2 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,019] INFO [LogLoader partition=__consumer_offsets-42, dir=/tmp/kafka-logs] Reloading from producer snapshot and rebuilding producer state from offset 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,019] INFO [ProducerStateManager partition=__consumer_offsets-42] Loading producer state from snapshot file 'SnapshotFile(offset=2, file=/tmp/kafka-logs/__consumer_offsets-42/00000000000000000002.snapshot)' (org.apache.kafka.storage.internals.log.ProducerStateManager) [2024-04-22 23:46:28,021] INFO [LogLoader partition=__consumer_offsets-42, dir=/tmp/kafka-logs] Producer state recovery took 2ms for snapshot load and 0ms for segment recovery from offset 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,023] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-42, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=42, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=2) with 1 segments, local-log-start-offset 0 and log-end-offset 2 in 6ms (40/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,029] INFO [LogLoader partition=__consumer_offsets-29, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,031] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-29, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=29, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 8ms (41/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,035] INFO [LogLoader partition=__consumer_offsets-16, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,036] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-16, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=16, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 6ms (42/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,039] INFO [LogLoader partition=__consumer_offsets-11, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,042] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-11, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=11, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 5ms (43/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,044] INFO [LogLoader partition=__consumer_offsets-18, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,047] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-18, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=18, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 5ms (44/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,052] INFO [LogLoader partition=__consumer_offsets-27, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,053] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-27, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=27, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 6ms (45/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,056] INFO [LogLoader partition=__consumer_offsets-20, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,060] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-20, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=20, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 6ms (46/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,063] INFO [LogLoader partition=__consumer_offsets-43, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,065] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-43, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=43, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 5ms (47/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,067] INFO [LogLoader partition=__consumer_offsets-44, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,073] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-44, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=44, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 9ms (48/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,076] INFO [LogLoader partition=__consumer_offsets-21, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,077] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-21, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=21, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 3ms (49/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,080] INFO [LogLoader partition=__consumer_offsets-19, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,081] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-19, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=19, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 4ms (50/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,085] INFO [LogLoader partition=__consumer_offsets-26, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,087] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-26, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=26, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 6ms (51/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,091] INFO [LogLoader partition=__consumer_offsets-10, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,093] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-10, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=10, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 5ms (52/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,098] INFO [LogLoader partition=__consumer_offsets-28, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,100] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-28, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=28, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 7ms (53/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,102] INFO [LogLoader partition=__consumer_offsets-17, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:28,104] INFO Completed load of Log(dir=/tmp/kafka-logs/__consumer_offsets-17, topicId=4XjyGzQVSRSdfl-yKbzxLA, topic=__consumer_offsets, partition=17, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments, local-log-start-offset 0 and log-end-offset 0 in 4ms (54/54 completed in /tmp/kafka-logs) (kafka.log.LogManager) [2024-04-22 23:46:28,119] INFO Loaded 54 logs in 567ms (kafka.log.LogManager) [2024-04-22 23:46:28,124] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager) [2024-04-22 23:46:28,125] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager) [2024-04-22 23:46:28,199] INFO [kafka-log-cleaner-thread-0]: Starting (kafka.log.LogCleaner$CleanerThread) [2024-04-22 23:46:28,218] INFO [feature-zk-node-event-process-thread]: Starting (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread) [2024-04-22 23:46:28,253] INFO [MetadataCache brokerId=0] Updated cache from existing None to latest Features(version=3.7-IV4, finalizedFeatures={}, finalizedFeaturesEpoch=0). (kafka.server.metadata.ZkMetadataCache) [2024-04-22 23:46:28,311] INFO [zk-broker-0-to-controller-forwarding-channel-manager]: Starting (kafka.server.NodeToControllerRequestThread) [2024-04-22 23:46:28,632] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas) [2024-04-22 23:46:28,652] INFO [SocketServer listenerType=ZK_BROKER, nodeId=0] Created data-plane acceptor and processors for endpoint : ListenerName(PLAINTEXT) (kafka.network.SocketServer) [2024-04-22 23:46:28,657] INFO [zk-broker-0-to-controller-alter-partition-channel-manager]: Starting (kafka.server.NodeToControllerRequestThread) [2024-04-22 23:46:28,688] INFO [ExpirationReaper-0-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2024-04-22 23:46:28,690] INFO [ExpirationReaper-0-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2024-04-22 23:46:28,692] INFO [ExpirationReaper-0-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2024-04-22 23:46:28,693] INFO [ExpirationReaper-0-ElectLeader]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2024-04-22 23:46:28,694] INFO [ExpirationReaper-0-RemoteFetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2024-04-22 23:46:28,706] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler) [2024-04-22 23:46:28,707] INFO [AddPartitionsToTxnSenderThread-0]: Starting (kafka.server.AddPartitionsToTxnManager) [2024-04-22 23:46:28,761] INFO Creating /brokers/ids/0 (is it secure? false) (kafka.zk.KafkaZkClient) [2024-04-22 23:46:28,792] INFO Stat of the created znode at /brokers/ids/0 is: 195,195,1713800788778,1713800788778,1,0,0,72073130001235968,202,0,195 (kafka.zk.KafkaZkClient) [2024-04-22 23:46:28,798] INFO Registered broker 0 at path /brokers/ids/0 with addresses: PLAINTEXT://localhost:9092, czxid (broker epoch): 195 (kafka.zk.KafkaZkClient) [2024-04-22 23:46:28,847] INFO [ExpirationReaper-0-topic]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2024-04-22 23:46:28,856] INFO [ExpirationReaper-0-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2024-04-22 23:46:28,857] INFO [ExpirationReaper-0-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2024-04-22 23:46:28,890] INFO [GroupCoordinator 0]: Starting up. (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:28,906] INFO [GroupCoordinator 0]: Startup complete. (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:28,930] INFO [TransactionCoordinator id=0] Starting up. (kafka.coordinator.transaction.TransactionCoordinator) [2024-04-22 23:46:28,935] INFO [TransactionCoordinator id=0] Startup complete. (kafka.coordinator.transaction.TransactionCoordinator) [2024-04-22 23:46:28,935] INFO [TxnMarkerSenderThread-0]: Starting (kafka.coordinator.transaction.TransactionMarkerChannelManager) [2024-04-22 23:46:28,983] INFO [ExpirationReaper-0-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2024-04-22 23:46:29,022] INFO [/config/changes-event-process-thread]: Starting (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread) [2024-04-22 23:46:29,102] INFO [Controller id=0, targetBrokerId=0] Node 0 disconnected. (org.apache.kafka.clients.NetworkClient) [2024-04-22 23:46:29,103] INFO [SocketServer listenerType=ZK_BROKER, nodeId=0] Enabling request processing. (kafka.network.SocketServer) [2024-04-22 23:46:29,104] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Node may not be available. (org.apache.kafka.clients.NetworkClient) [2024-04-22 23:46:29,112] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.DataPlaneAcceptor) [2024-04-22 23:46:29,114] INFO [Controller id=0, targetBrokerId=0] Client requested connection close from node 0 (org.apache.kafka.clients.NetworkClient) [2024-04-22 23:46:29,137] INFO Kafka version: 3.7.0 (org.apache.kafka.common.utils.AppInfoParser) [2024-04-22 23:46:29,137] INFO Kafka commitId: 2ae524ed625438c5 (org.apache.kafka.common.utils.AppInfoParser) [2024-04-22 23:46:29,137] INFO Kafka startTimeMs: 1713800789119 (org.apache.kafka.common.utils.AppInfoParser) [2024-04-22 23:46:29,149] INFO [KafkaServer id=0] started (kafka.server.KafkaServer) [2024-04-22 23:46:29,270] INFO [zk-broker-0-to-controller-alter-partition-channel-manager]: Recorded new controller, from now on will use node localhost:9092 (id: 0 rack: null) (kafka.server.NodeToControllerRequestThread) [2024-04-22 23:46:29,334] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions HashSet(__consumer_offsets-22, __consumer_offsets-30, __consumer_offsets-35, yujin_topic_1-0, __consumer_offsets-37, __consumer_offsets-38, __consumer_offsets-13, __consumer_offsets-8, __consumer_offsets-21, __consumer_offsets-4, __consumer_offsets-27, __consumer_offsets-7, __consumer_offsets-9, __consumer_offsets-46, quickstart-events-0, __consumer_offsets-25, __consumer_offsets-41, __consumer_offsets-33, __consumer_offsets-23, __consumer_offsets-49, __consumer_offsets-47, __consumer_offsets-16, __consumer_offsets-28, __consumer_offsets-31, __consumer_offsets-36, __consumer_offsets-42, __consumer_offsets-3, __consumer_offsets-18, __consumer_offsets-15, __consumer_offsets-24, __consumer_offsets-17, __consumer_offsets-48, __consumer_offsets-19, __consumer_offsets-11, yujin_topic_01-0, __consumer_offsets-2, __consumer_offsets-43, __consumer_offsets-6, __consumer_offsets-14, __consumer_offsets-20, __consumer_offsets-0, __consumer_offsets-44, __consumer_offsets-39, __consumer_offsets-12, __consumer_offsets-45, __consumer_offsets-1, __consumer_offsets-5, __consumer_offsets-26, __consumer_offsets-29, __consumer_offsets-34, yujin_topic_02-0, __consumer_offsets-10, __consumer_offsets-32, __consumer_offsets-40) (kafka.server.ReplicaFetcherManager) [2024-04-22 23:46:29,348] INFO [Partition __consumer_offsets-3 broker=0] Log loaded for partition __consumer_offsets-3 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,352] INFO [zk-broker-0-to-controller-forwarding-channel-manager]: Recorded new controller, from now on will use node localhost:9092 (id: 0 rack: null) (kafka.server.NodeToControllerRequestThread) [2024-04-22 23:46:29,359] INFO [Partition quickstart-events-0 broker=0] Log loaded for partition quickstart-events-0 with initial high watermark 5 (kafka.cluster.Partition) [2024-04-22 23:46:29,361] INFO [Partition __consumer_offsets-18 broker=0] Log loaded for partition __consumer_offsets-18 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,365] INFO [Partition __consumer_offsets-41 broker=0] Log loaded for partition __consumer_offsets-41 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,372] INFO [Partition __consumer_offsets-10 broker=0] Log loaded for partition __consumer_offsets-10 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,376] INFO [Partition yujin_topic_01-0 broker=0] Log loaded for partition yujin_topic_01-0 with initial high watermark 5 (kafka.cluster.Partition) [2024-04-22 23:46:29,377] INFO [Partition yujin_topic_02-0 broker=0] Log loaded for partition yujin_topic_02-0 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,382] INFO [Partition yujin_topic_1-0 broker=0] Log loaded for partition yujin_topic_1-0 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,390] INFO [Partition __consumer_offsets-33 broker=0] Log loaded for partition __consumer_offsets-33 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,396] INFO [Partition __consumer_offsets-48 broker=0] Log loaded for partition __consumer_offsets-48 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,402] INFO [Partition __consumer_offsets-19 broker=0] Log loaded for partition __consumer_offsets-19 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,407] INFO [Partition __consumer_offsets-34 broker=0] Log loaded for partition __consumer_offsets-34 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,412] INFO [Partition __consumer_offsets-4 broker=0] Log loaded for partition __consumer_offsets-4 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,418] INFO [Partition __consumer_offsets-11 broker=0] Log loaded for partition __consumer_offsets-11 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,423] INFO [Partition __consumer_offsets-26 broker=0] Log loaded for partition __consumer_offsets-26 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,429] INFO [Partition __consumer_offsets-49 broker=0] Log loaded for partition __consumer_offsets-49 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,434] INFO [Partition __consumer_offsets-39 broker=0] Log loaded for partition __consumer_offsets-39 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,439] INFO [Partition __consumer_offsets-9 broker=0] Log loaded for partition __consumer_offsets-9 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,445] INFO [Partition __consumer_offsets-24 broker=0] Log loaded for partition __consumer_offsets-24 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,451] INFO [Partition __consumer_offsets-31 broker=0] Log loaded for partition __consumer_offsets-31 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,456] INFO [Partition __consumer_offsets-46 broker=0] Log loaded for partition __consumer_offsets-46 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,463] INFO [Partition __consumer_offsets-1 broker=0] Log loaded for partition __consumer_offsets-1 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,467] INFO [Partition __consumer_offsets-16 broker=0] Log loaded for partition __consumer_offsets-16 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,471] INFO [Partition __consumer_offsets-2 broker=0] Log loaded for partition __consumer_offsets-2 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,476] INFO [Partition __consumer_offsets-25 broker=0] Log loaded for partition __consumer_offsets-25 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,482] INFO [Partition __consumer_offsets-40 broker=0] Log loaded for partition __consumer_offsets-40 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,488] INFO [Partition __consumer_offsets-47 broker=0] Log loaded for partition __consumer_offsets-47 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,494] INFO [Partition __consumer_offsets-17 broker=0] Log loaded for partition __consumer_offsets-17 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,499] INFO [Partition __consumer_offsets-32 broker=0] Log loaded for partition __consumer_offsets-32 with initial high watermark 3 (kafka.cluster.Partition) [2024-04-22 23:46:29,499] INFO [Partition __consumer_offsets-37 broker=0] Log loaded for partition __consumer_offsets-37 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,504] INFO [Partition __consumer_offsets-7 broker=0] Log loaded for partition __consumer_offsets-7 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,508] INFO [Partition __consumer_offsets-22 broker=0] Log loaded for partition __consumer_offsets-22 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,513] INFO [Partition __consumer_offsets-29 broker=0] Log loaded for partition __consumer_offsets-29 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,517] INFO [Partition __consumer_offsets-44 broker=0] Log loaded for partition __consumer_offsets-44 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,521] INFO [Partition __consumer_offsets-14 broker=0] Log loaded for partition __consumer_offsets-14 with initial high watermark 3 (kafka.cluster.Partition) [2024-04-22 23:46:29,521] INFO [Partition __consumer_offsets-23 broker=0] Log loaded for partition __consumer_offsets-23 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,525] INFO [Partition __consumer_offsets-38 broker=0] Log loaded for partition __consumer_offsets-38 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,530] INFO [Partition __consumer_offsets-8 broker=0] Log loaded for partition __consumer_offsets-8 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,535] INFO [Partition __consumer_offsets-45 broker=0] Log loaded for partition __consumer_offsets-45 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,539] INFO [Partition __consumer_offsets-15 broker=0] Log loaded for partition __consumer_offsets-15 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,544] INFO [Partition __consumer_offsets-30 broker=0] Log loaded for partition __consumer_offsets-30 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,548] INFO [Partition __consumer_offsets-0 broker=0] Log loaded for partition __consumer_offsets-0 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,553] INFO [Partition __consumer_offsets-35 broker=0] Log loaded for partition __consumer_offsets-35 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,558] INFO [Partition __consumer_offsets-5 broker=0] Log loaded for partition __consumer_offsets-5 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,563] INFO [Partition __consumer_offsets-20 broker=0] Log loaded for partition __consumer_offsets-20 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,568] INFO [Partition __consumer_offsets-27 broker=0] Log loaded for partition __consumer_offsets-27 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,573] INFO [Partition __consumer_offsets-42 broker=0] Log loaded for partition __consumer_offsets-42 with initial high watermark 2 (kafka.cluster.Partition) [2024-04-22 23:46:29,573] INFO [Partition __consumer_offsets-12 broker=0] Log loaded for partition __consumer_offsets-12 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,578] INFO [Partition __consumer_offsets-21 broker=0] Log loaded for partition __consumer_offsets-21 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,583] INFO [Partition __consumer_offsets-36 broker=0] Log loaded for partition __consumer_offsets-36 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,587] INFO [Partition __consumer_offsets-6 broker=0] Log loaded for partition __consumer_offsets-6 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,593] INFO [Partition __consumer_offsets-43 broker=0] Log loaded for partition __consumer_offsets-43 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,599] INFO [Partition __consumer_offsets-13 broker=0] Log loaded for partition __consumer_offsets-13 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,603] INFO [Partition __consumer_offsets-28 broker=0] Log loaded for partition __consumer_offsets-28 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:46:29,618] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 3 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,621] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-3 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,628] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 18 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-18 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 41 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-41 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 10 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-10 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 33 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-33 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 48 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-48 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 19 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-19 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 34 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-34 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 4 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-4 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 11 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-11 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 26 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-26 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 49 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-49 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 39 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-39 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 9 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-9 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 24 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-24 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 31 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-31 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 46 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-46 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 1 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-1 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 16 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-16 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 2 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-2 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,629] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 25 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,629] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-25 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,630] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 40 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,630] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-40 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,630] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 47 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,630] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-47 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 17 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-17 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 32 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-32 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 37 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-37 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 7 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-7 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 22 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-22 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 29 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-29 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 44 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-44 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 14 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-14 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 23 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-23 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 38 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-38 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 8 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-8 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 45 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-45 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 15 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-15 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 30 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-30 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 0 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-0 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 35 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-35 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,631] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 5 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,631] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-5 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,632] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 20 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,632] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-20 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,632] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 27 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,632] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-27 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,632] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 42 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,632] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-42 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,632] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 12 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,632] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-12 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,632] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 21 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,632] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-21 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,632] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 36 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,632] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-36 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,632] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 6 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,632] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-6 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,632] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 43 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,632] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-43 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,632] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 13 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,632] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-13 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,632] INFO [GroupCoordinator 0]: Elected as the group coordinator for partition 28 in epoch 0 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,632] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-28 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,634] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-3 in 10 milliseconds for epoch 0, of which 6 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,638] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-18 in 6 milliseconds for epoch 0, of which 6 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,639] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-41 in 9 milliseconds for epoch 0, of which 9 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,639] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-10 in 10 milliseconds for epoch 0, of which 10 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,640] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-33 in 11 milliseconds for epoch 0, of which 11 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,640] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-48 in 11 milliseconds for epoch 0, of which 11 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,640] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-19 in 11 milliseconds for epoch 0, of which 11 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,641] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-34 in 11 milliseconds for epoch 0, of which 11 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,641] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-4 in 12 milliseconds for epoch 0, of which 12 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,641] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-11 in 12 milliseconds for epoch 0, of which 12 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,641] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-26 in 12 milliseconds for epoch 0, of which 12 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,643] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-49 in 14 milliseconds for epoch 0, of which 13 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,643] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-39 in 14 milliseconds for epoch 0, of which 14 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,644] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-9 in 15 milliseconds for epoch 0, of which 14 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,644] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-24 in 15 milliseconds for epoch 0, of which 15 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,644] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-31 in 15 milliseconds for epoch 0, of which 15 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,644] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-46 in 15 milliseconds for epoch 0, of which 15 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,644] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-1 in 15 milliseconds for epoch 0, of which 15 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,644] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-16 in 15 milliseconds for epoch 0, of which 15 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,644] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-2 in 15 milliseconds for epoch 0, of which 15 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,645] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-25 in 16 milliseconds for epoch 0, of which 15 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,648] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-40 in 17 milliseconds for epoch 0, of which 15 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,648] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-47 in 17 milliseconds for epoch 0, of which 17 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,649] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-17 in 18 milliseconds for epoch 0, of which 17 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,688] INFO Loaded member MemberMetadata(memberId=console-consumer-e9bb4318-32d6-4f7a-8d37-ffc405d0ebff, groupInstanceId=None, clientId=console-consumer, clientHost=/127.0.0.1, sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, supportedProtocols=List(range)) in group console-consumer-29622 with generation 1. (kafka.coordinator.group.GroupMetadata$) [2024-04-22 23:46:29,694] INFO Loaded member MemberMetadata(memberId=console-consumer-6c552bcc-106a-4d9c-85c6-601c3277e044, groupInstanceId=None, clientId=console-consumer, clientHost=/127.0.0.1, sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, supportedProtocols=List(range)) in group console-consumer-29622 with generation 3. (kafka.coordinator.group.GroupMetadata$) [2024-04-22 23:46:29,699] INFO [GroupCoordinator 0]: Loading group metadata for console-consumer-29622 with generation 3 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,703] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-32 in 72 milliseconds for epoch 0, of which 18 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,704] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-37 in 73 milliseconds for epoch 0, of which 72 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,704] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-7 in 73 milliseconds for epoch 0, of which 73 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,704] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-22 in 73 milliseconds for epoch 0, of which 73 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,704] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-29 in 73 milliseconds for epoch 0, of which 73 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,704] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-44 in 73 milliseconds for epoch 0, of which 73 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,707] INFO Loaded member MemberMetadata(memberId=console-consumer-cecd68e3-c8b3-4b45-a8cd-2bf36e879390, groupInstanceId=None, clientId=console-consumer, clientHost=/127.0.0.1, sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, supportedProtocols=List(range)) in group console-consumer-22081 with generation 1. (kafka.coordinator.group.GroupMetadata$) [2024-04-22 23:46:29,708] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-14 in 77 milliseconds for epoch 0, of which 73 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,708] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-23 in 77 milliseconds for epoch 0, of which 77 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,708] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-38 in 77 milliseconds for epoch 0, of which 77 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,708] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-8 in 77 milliseconds for epoch 0, of which 77 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,709] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-45 in 78 milliseconds for epoch 0, of which 77 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,709] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-15 in 78 milliseconds for epoch 0, of which 78 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,709] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-30 in 78 milliseconds for epoch 0, of which 78 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,709] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-0 in 78 milliseconds for epoch 0, of which 78 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,709] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-35 in 78 milliseconds for epoch 0, of which 78 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,709] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-5 in 78 milliseconds for epoch 0, of which 78 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,709] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-20 in 77 milliseconds for epoch 0, of which 77 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,709] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-27 in 77 milliseconds for epoch 0, of which 77 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,711] INFO Loaded member MemberMetadata(memberId=console-consumer-5297c28c-9958-45c4-b7d3-8c29148d45db, groupInstanceId=None, clientId=console-consumer, clientHost=/127.0.0.1, sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, supportedProtocols=List(range)) in group console-consumer-9815 with generation 1. (kafka.coordinator.group.GroupMetadata$) [2024-04-22 23:46:29,713] INFO [GroupCoordinator 0]: Loading group metadata for console-consumer-9815 with generation 2 (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:46:29,713] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-42 in 81 milliseconds for epoch 0, of which 77 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,713] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-12 in 81 milliseconds for epoch 0, of which 81 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,713] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-21 in 81 milliseconds for epoch 0, of which 81 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,713] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-36 in 81 milliseconds for epoch 0, of which 81 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,714] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-6 in 82 milliseconds for epoch 0, of which 81 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,714] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-43 in 82 milliseconds for epoch 0, of which 82 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,714] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-13 in 82 milliseconds for epoch 0, of which 82 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:29,714] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-28 in 82 milliseconds for epoch 0, of which 82 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) [2024-04-22 23:46:47,267] INFO Creating topic wuyujin1997_topic_01 with configuration {} and initial partition assignment HashMap(0 -> ArrayBuffer(0)) (kafka.zk.AdminZkClient) [2024-04-22 23:46:47,365] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(wuyujin1997_topic_01-0) (kafka.server.ReplicaFetcherManager) [2024-04-22 23:46:47,386] INFO [LogLoader partition=wuyujin1997_topic_01-0, dir=/tmp/kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2024-04-22 23:46:47,392] INFO Created log for partition wuyujin1997_topic_01-0 in /tmp/kafka-logs/wuyujin1997_topic_01-0 with properties {} (kafka.log.LogManager) [2024-04-22 23:46:47,394] INFO [Partition wuyujin1997_topic_01-0 broker=0] No checkpointed highwatermark is found for partition wuyujin1997_topic_01-0 (kafka.cluster.Partition) [2024-04-22 23:46:47,396] INFO [Partition wuyujin1997_topic_01-0 broker=0] Log loaded for partition wuyujin1997_topic_01-0 with initial high watermark 0 (kafka.cluster.Partition) [2024-04-22 23:47:06,327] INFO [GroupCoordinator 0]: Dynamic member with unknown member id joins group console-consumer-85589 in Empty state. Created a new member id console-consumer-4dc80265-5820-4b2e-b00d-05bae42d0c22 and request the member to rejoin with this id. (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:47:06,338] INFO [GroupCoordinator 0]: Preparing to rebalance group console-consumer-85589 in state PreparingRebalance with old generation 0 (__consumer_offsets-26) (reason: Adding new member console-consumer-4dc80265-5820-4b2e-b00d-05bae42d0c22 with group instance id None; client reason: need to re-join with the given member-id: console-consumer-4dc80265-5820-4b2e-b00d-05bae42d0c22) (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:47:06,345] INFO [GroupCoordinator 0]: Stabilized group console-consumer-85589 generation 1 (__consumer_offsets-26) with 1 members (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:47:06,367] INFO [GroupCoordinator 0]: Assignment received from leader console-consumer-4dc80265-5820-4b2e-b00d-05bae42d0c22 for group console-consumer-85589 for generation 1. The group has 1 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:48:45,594] INFO [GroupCoordinator 0]: Preparing to rebalance group console-consumer-29622 in state PreparingRebalance with old generation 3 (__consumer_offsets-32) (reason: Removing member console-consumer-6c552bcc-106a-4d9c-85c6-601c3277e044 on LeaveGroup; client reason: the consumer is being closed) (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:48:45,596] INFO [GroupCoordinator 0]: Group console-consumer-29622 with generation 4 is now empty (__consumer_offsets-32) (kafka.coordinator.group.GroupCoordinator) [2024-04-22 23:48:45,607] INFO [GroupCoordinator 0]: Member MemberMetadata(memberId=console-consumer-6c552bcc-106a-4d9c-85c6-601c3277e044, groupInstanceId=None, clientId=console-consumer, clientHost=/127.0.0.1, sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, supportedProtocols=List(range)) has left group console-consumer-29622 through explicit `LeaveGroup`; client reason: the consumer is being closed (kafka.coordinator.group.GroupCoordinator)- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
- 71
- 72
- 73
- 74
- 75
- 76
- 77
- 78
- 79
- 80
- 81
- 82
- 83
- 84
- 85
- 86
- 87
- 88
- 89
- 90
- 91
- 92
- 93
- 94
- 95
- 96
- 97
- 98
- 99
- 100
- 101
- 102
- 103
- 104
- 105
- 106
- 107
- 108
- 109
- 110
- 111
- 112
- 113
- 114
- 115
- 116
- 117
- 118
- 119
- 120
- 121
- 122
- 123
- 124
- 125
- 126
- 127
- 128
- 129
- 130
- 131
- 132
- 133
- 134
- 135
- 136
- 137
- 138
- 139
- 140
- 141
- 142
- 143
- 144
- 145
- 146
- 147
- 148
- 149
- 150
- 151
- 152
- 153
- 154
- 155
- 156
- 157
- 158
- 159
- 160
- 161
- 162
- 163
- 164
- 165
- 166
- 167
- 168
- 169
- 170
- 171
- 172
- 173
- 174
- 175
- 176
- 177
- 178
- 179
- 180
- 181
- 182
- 183
- 184
- 185
- 186
- 187
- 188
- 189
- 190
- 191
- 192
- 193
- 194
- 195
- 196
- 197
- 198
- 199
- 200
- 201
- 202
- 203
- 204
- 205
- 206
- 207
- 208
- 209
- 210
- 211
- 212
- 213
- 214
- 215
- 216
- 217
- 218
- 219
- 220
- 221
- 222
- 223
- 224
- 225
- 226
- 227
- 228
- 229
- 230
- 231
- 232
- 233
- 234
- 235
- 236
- 237
- 238
- 239
- 240
- 241
- 242
- 243
- 244
- 245
- 246
- 247
- 248
- 249
- 250
- 251
- 252
- 253
- 254
- 255
- 256
- 257
- 258
- 259
- 260
- 261
- 262
- 263
- 264
- 265
- 266
- 267
- 268
- 269
- 270
- 271
- 272
- 273
- 274
- 275
- 276
- 277
- 278
- 279
- 280
- 281
- 282
- 283
- 284
- 285
- 286
- 287
- 288
- 289
- 290
- 291
- 292
- 293
- 294
- 295
- 296
- 297
- 298
- 299
- 300
- 301
- 302
- 303
- 304
- 305
- 306
- 307
- 308
- 309
- 310
- 311
- 312
- 313
- 314
- 315
- 316
- 317
- 318
- 319
- 320
- 321
- 322
- 323
- 324
- 325
- 326
- 327
- 328
- 329
- 330
- 331
- 332
- 333
- 334
- 335
- 336
- 337
- 338
- 339
- 340
- 341
- 342
- 343
- 344
- 345
- 346
- 347
- 348
- 349
- 350
- 351
- 352
- 353
- 354
- 355
- 356
- 357
- 358
- 359
- 360
- 361
- 362
- 363
- 364
- 365
- 366
- 367
- 368
- 369
- 370
- 371
- 372
- 373
- 374
- 375
- 376
- 377
- 378
- 379
- 380
- 381
- 382
- 383
- 384
- 385
- 386
- 387
- 388
- 389
- 390
- 391
- 392
- 393
- 394
- 395
- 396
- 397
- 398
- 399
- 400
- 401
- 402
- 403
- 404
- 405
- 406
- 407
- 408
- 409
- 410
- 411
- 412
- 413
- 414
- 415
- 416
- 417
- 418
- 419
- 420
- 421
- 422
- 423
- 424
- 425
- 426
- 427
- 428
- 429
- 430
- 431
- 432
- 433
- 434
- 435
- 436
- 437
- 438
- 439
- 440
- 441
- 442
- 443
- 444
- 445
- 446
- 447
- 448
- 449
- 450
- 451
- 452
- 453
- 454
- 455
- 456
- 457
- 458
- 459
- 460
- 461
- 462
- 463
- 464
- 465
- 466
- 467
- 468
- 469
- 470
- 471
- 472
- 473
- 474
- 475
- 476
- 477
- 478
- 479
- 480
- 481
- 482
- 483
- 484
- 485
- 486
- 487
- 488
- 489
- 490
- 491
- 492
- 493
- 494
- 495
- 496
- 497
- 498
- 499
- 500
- 501
- 502
- 503
- 504
- 505
- 506
- 507
- 508
- 509
- 510
- 511
- 512
- 513
- 514
- 515
- 516
- 517
- 518
- 519
- 520
- 521
- 522
- 523
- 524
- 525
- 526
- 527
- 528
- 529
- 530
- 531
- 532
- 533
- 534
- 535
- 536
- 537
- 538
- 539
- 540
- 541
- 542
- 543
- 544
- 545
- 546
- 547
- 548
- 549
- 550
- 551
- 552
- 553
- 554
- 555
- 556
- 557
- 558
- 559
- 560
- 561
- 562
- 563
- 564
- 565
- 566
- 567
- 568
- 569
- 570
- 571
- 572
- 573
- 574
- 575
- 576
- 577
- 578
- 579
- 580
- 581
- 582
- 583
- 584
- 585
- 586
- 587
- 588
- 589
- 590
- 591
- 592
- 593
- 594
- 595
- 596
- 597
- 598
- 599
- 600
- 601
- 602
- 603
- 604
- 605
- 606
- 607
- 608
- 609
- 610
- 611
- 612
- 613
- 614
- 615
- 616
- 617
- 618
- 619
- 620
- 621
- 622
- 623
- 624
- 625
- 626
- 627
- 628
- 629
- 630
- 631
- 632
- 633
- 634
- 635
- 636
- 637
- 638
- 639
- 640
- 641
- 642
- 643
- 644
- 645
- 646
- 647
- 648
- 649
- 650
- 651
- 652
- 653
- 654
- 655
- 656
- 657
- 658
- 659
- 660
- 661
- 662
- 663
- 664
- 665
- 666
- 667
- 668
- 669
- 670
- 671
- 672
- 673
- 674
- 675
- 676
- 677
- 678
- 679
- 680
- 681
- 682
- 683
- 684
- 685
- 686
- 687
- 688
- 689
- 690
- 691
- 692
- 693
- 694
- 695
- 696
- 697
- 698
- 699
- 700
- 701
- 702
- 703
- 704
- 705
- 706
- 707
- 708
- 709
- 710
- 711
- 712
- 713
- 714
- 715
- 716
- 717
- 718
- 719
- 720
- 721
- 722
- 723
- 724
- 725
- 726
- 727
- 728
- 729
- 730
- 731
- 732
create topic && describe topic
wuyujin1997@wyjmacm1 kafka_2.13-3.7.0 % bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --topic wuyujin1997_topic_01 WARNING: Due to limitations in metric names, topics with a period ('.') or underscore ('_') could collide. To avoid issues it is best to use either, but not both. Created topic wuyujin1997_topic_01. wuyujin1997@wyjmacm1 kafka_2.13-3.7.0 % wuyujin1997@wyjmacm1 kafka_2.13-3.7.0 % bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic wuyujin1997_topic_01 Topic: wuyujin1997_topic_01 TopicId: o2UhNWWLRAezW7bMrKt0oA PartitionCount: 1 ReplicationFactor: 1 Configs: Topic: wuyujin1997_topic_01 Partition: 0 Leader: 0 Replicas: 0 Isr: 0 wuyujin1997@wyjmacm1 kafka_2.13-3.7.0 %- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
-
相关阅读:
10、matlab中字符、数字、矩阵、字符串和元胞合并为字符串并将字符串以不同格式写入读出excel
Jmeter接口测试---随机数、加密、cookie鉴权、断言、CSV参数化
c语言系统编程十三：Linux线程间的同步与互斥
在javascript中的公共、私有和受保护的类可见性模式
Bugly iOS自动导入符号表
线性表章节课后习题答案集锦
从一线开发到技术总监，你就差一个赶鸭子上架
【软件测试】超细HttpRunner接口自动化框架使用案例，一篇策底打通...
Eureka介绍与使用
在输入框里直接粘贴图片
- 原文地址：https://blog.csdn.net/wuyujin1997/article/details/138097264
