kafka 命令行使用消息的写入和读取 quickstart

本文主要是介绍kafka 命令行使用消息的写入和读取 quickstart，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章目录

- Intro
- 命令
- 日志
- - zookeeper server
  - kafka server
  - create topic && describe topic

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_01bin/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 窗口就会接收到心的消息行。

日志

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=<NA> (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)

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 = nullalter.config.policy.class.name = nullalter.log.dirs.replication.quota.window.num = 11alter.log.dirs.replication.quota.window.size.seconds = 1authorizer.class.name = auto.create.topics.enable = trueauto.include.jmx.reporter = trueauto.leader.rebalance.enable = truebackground.threads = 10broker.heartbeat.interval.ms = 2000broker.id = 0broker.id.generation.enable = truebroker.rack = nullbroker.session.timeout.ms = 9000client.quota.callback.class = nullcompression.type = producerconnection.failed.authentication.delay.ms = 100connections.max.idle.ms = 600000connections.max.reauth.ms = 0control.plane.listener.name = nullcontrolled.shutdown.enable = truecontrolled.shutdown.max.retries = 3controlled.shutdown.retry.backoff.ms = 5000controller.listener.names = nullcontroller.quorum.append.linger.ms = 25controller.quorum.election.backoff.max.ms = 1000controller.quorum.election.timeout.ms = 1000controller.quorum.fetch.timeout.ms = 2000controller.quorum.request.timeout.ms = 2000controller.quorum.retry.backoff.ms = 20controller.quorum.voters = []controller.quota.window.num = 11controller.quota.window.size.seconds = 1controller.socket.timeout.ms = 30000create.topic.policy.class.name = nulldefault.replication.factor = 1delegation.token.expiry.check.interval.ms = 3600000delegation.token.expiry.time.ms = 86400000delegation.token.master.key = nulldelegation.token.max.lifetime.ms = 604800000delegation.token.secret.key = nulldelete.records.purgatory.purge.interval.requests = 1delete.topic.enable = trueearly.start.listeners = nulleligible.leader.replicas.enable = falsefetch.max.bytes = 57671680fetch.purgatory.purge.interval.requests = 1000group.consumer.assignors = [org.apache.kafka.coordinator.group.assignor.UniformAssignor, org.apache.kafka.coordinator.group.assignor.RangeAssignor]group.consumer.heartbeat.interval.ms = 5000group.consumer.max.heartbeat.interval.ms = 15000group.consumer.max.session.timeout.ms = 60000group.consumer.max.size = 2147483647group.consumer.min.heartbeat.interval.ms = 5000group.consumer.min.session.timeout.ms = 45000group.consumer.session.timeout.ms = 45000group.coordinator.new.enable = falsegroup.coordinator.rebalance.protocols = [classic]group.coordinator.threads = 1group.initial.rebalance.delay.ms = 0group.max.session.timeout.ms = 1800000group.max.size = 2147483647group.min.session.timeout.ms = 6000initial.broker.registration.timeout.ms = 60000inter.broker.listener.name = nullinter.broker.protocol.version = 3.7-IV4kafka.metrics.polling.interval.secs = 10kafka.metrics.reporters = []leader.imbalance.check.interval.seconds = 300leader.imbalance.per.broker.percentage = 10listener.security.protocol.map = PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSLlisteners = PLAINTEXT://:9092log.cleaner.backoff.ms = 15000log.cleaner.dedupe.buffer.size = 134217728log.cleaner.delete.retention.ms = 86400000log.cleaner.enable = truelog.cleaner.io.buffer.load.factor = 0.9log.cleaner.io.buffer.size = 524288log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308log.cleaner.max.compaction.lag.ms = 9223372036854775807log.cleaner.min.cleanable.ratio = 0.5log.cleaner.min.compaction.lag.ms = 0log.cleaner.threads = 1log.cleanup.policy = [delete]log.dir = /tmp/kafka-logslog.dirs = /tmp/kafka-logslog.flush.interval.messages = 9223372036854775807log.flush.interval.ms = nulllog.flush.offset.checkpoint.interval.ms = 60000log.flush.scheduler.interval.ms = 9223372036854775807log.flush.start.offset.checkpoint.interval.ms = 60000log.index.interval.bytes = 4096log.index.size.max.bytes = 10485760log.local.retention.bytes = -2log.local.retention.ms = -2log.message.downconversion.enable = truelog.message.format.version = 3.0-IV1log.message.timestamp.after.max.ms = 9223372036854775807log.message.timestamp.before.max.ms = 9223372036854775807log.message.timestamp.difference.max.ms = 9223372036854775807log.message.timestamp.type = CreateTimelog.preallocate = falselog.retention.bytes = -1log.retention.check.interval.ms = 300000log.retention.hours = 168log.retention.minutes = nulllog.retention.ms = nulllog.roll.hours = 168log.roll.jitter.hours = 0log.roll.jitter.ms = nulllog.roll.ms = nulllog.segment.bytes = 1073741824log.segment.delete.delay.ms = 60000max.connection.creation.rate = 2147483647max.connections = 2147483647max.connections.per.ip = 2147483647max.connections.per.ip.overrides = max.incremental.fetch.session.cache.slots = 1000message.max.bytes = 1048588metadata.log.dir = nullmetadata.log.max.record.bytes.between.snapshots = 20971520metadata.log.max.snapshot.interval.ms = 3600000metadata.log.segment.bytes = 1073741824metadata.log.segment.min.bytes = 8388608metadata.log.segment.ms = 604800000metadata.max.idle.interval.ms = 500metadata.max.retention.bytes = 104857600metadata.max.retention.ms = 604800000metric.reporters = []metrics.num.samples = 2metrics.recording.level = INFOmetrics.sample.window.ms = 30000min.insync.replicas = 1node.id = 0num.io.threads = 8num.network.threads = 3num.partitions = 1num.recovery.threads.per.data.dir = 1num.replica.alter.log.dirs.threads = nullnum.replica.fetchers = 1offset.metadata.max.bytes = 4096offsets.commit.required.acks = -1offsets.commit.timeout.ms = 5000offsets.load.buffer.size = 5242880offsets.retention.check.interval.ms = 600000offsets.retention.minutes = 10080offsets.topic.compression.codec = 0offsets.topic.num.partitions = 50offsets.topic.replication.factor = 1offsets.topic.segment.bytes = 104857600password.encoder.cipher.algorithm = AES/CBC/PKCS5Paddingpassword.encoder.iterations = 4096password.encoder.key.length = 128password.encoder.keyfactory.algorithm = nullpassword.encoder.old.secret = nullpassword.encoder.secret = nullprincipal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilderprocess.roles = []producer.id.expiration.check.interval.ms = 600000producer.id.expiration.ms = 86400000producer.purgatory.purge.interval.requests = 1000queued.max.request.bytes = -1queued.max.requests = 500quota.window.num = 11quota.window.size.seconds = 1remote.log.index.file.cache.total.size.bytes = 1073741824remote.log.manager.task.interval.ms = 30000remote.log.manager.task.retry.backoff.max.ms = 30000remote.log.manager.task.retry.backoff.ms = 500remote.log.manager.task.retry.jitter = 0.2remote.log.manager.thread.pool.size = 10remote.log.metadata.custom.metadata.max.bytes = 128remote.log.metadata.manager.class.name = org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManagerremote.log.metadata.manager.class.path = nullremote.log.metadata.manager.impl.prefix = rlmm.config.remote.log.metadata.manager.listener.name = nullremote.log.reader.max.pending.tasks = 100remote.log.reader.threads = 10remote.log.storage.manager.class.name = nullremote.log.storage.manager.class.path = nullremote.log.storage.manager.impl.prefix = rsm.config.remote.log.storage.system.enable = falsereplica.fetch.backoff.ms = 1000replica.fetch.max.bytes = 1048576replica.fetch.min.bytes = 1replica.fetch.response.max.bytes = 10485760replica.fetch.wait.max.ms = 500replica.high.watermark.checkpoint.interval.ms = 5000replica.lag.time.max.ms = 30000replica.selector.class = nullreplica.socket.receive.buffer.bytes = 65536replica.socket.timeout.ms = 30000replication.quota.window.num = 11replication.quota.window.size.seconds = 1request.timeout.ms = 30000reserved.broker.max.id = 1000sasl.client.callback.handler.class = nullsasl.enabled.mechanisms = [GSSAPI]sasl.jaas.config = nullsasl.kerberos.kinit.cmd = /usr/bin/kinitsasl.kerberos.min.time.before.relogin = 60000sasl.kerberos.principal.to.local.rules = [DEFAULT]sasl.kerberos.service.name = nullsasl.kerberos.ticket.renew.jitter = 0.05sasl.kerberos.ticket.renew.window.factor = 0.8sasl.login.callback.handler.class = nullsasl.login.class = nullsasl.login.connect.timeout.ms = nullsasl.login.read.timeout.ms = nullsasl.login.refresh.buffer.seconds = 300sasl.login.refresh.min.period.seconds = 60sasl.login.refresh.window.factor = 0.8sasl.login.refresh.window.jitter = 0.05sasl.login.retry.backoff.max.ms = 10000sasl.login.retry.backoff.ms = 100sasl.mechanism.controller.protocol = GSSAPIsasl.mechanism.inter.broker.protocol = GSSAPIsasl.oauthbearer.clock.skew.seconds = 30sasl.oauthbearer.expected.audience = nullsasl.oauthbearer.expected.issuer = nullsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100sasl.oauthbearer.jwks.endpoint.url = nullsasl.oauthbearer.scope.claim.name = scopesasl.oauthbearer.sub.claim.name = subsasl.oauthbearer.token.endpoint.url = nullsasl.server.callback.handler.class = nullsasl.server.max.receive.size = 524288security.inter.broker.protocol = PLAINTEXTsecurity.providers = nullserver.max.startup.time.ms = 9223372036854775807socket.connection.setup.timeout.max.ms = 30000socket.connection.setup.timeout.ms = 10000socket.listen.backlog.size = 50socket.receive.buffer.bytes = 102400socket.request.max.bytes = 104857600socket.send.buffer.bytes = 102400ssl.allow.dn.changes = falsessl.allow.san.changes = falsessl.cipher.suites = []ssl.client.auth = nonessl.enabled.protocols = [TLSv1.2, TLSv1.3]ssl.endpoint.identification.algorithm = httpsssl.engine.factory.class = nullssl.key.password = nullssl.keymanager.algorithm = SunX509ssl.keystore.certificate.chain = nullssl.keystore.key = nullssl.keystore.location = nullssl.keystore.password = nullssl.keystore.type = JKSssl.principal.mapping.rules = DEFAULTssl.protocol = TLSv1.3ssl.provider = nullssl.secure.random.implementation = nullssl.trustmanager.algorithm = PKIXssl.truststore.certificates = nullssl.truststore.location = nullssl.truststore.password = nullssl.truststore.type = JKStelemetry.max.bytes = 1048576transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000transaction.max.timeout.ms = 900000transaction.partition.verification.enable = truetransaction.remove.expired.transaction.cleanup.interval.ms = 3600000transaction.state.log.load.buffer.size = 5242880transaction.state.log.min.isr = 1transaction.state.log.num.partitions = 50transaction.state.log.replication.factor = 1transaction.state.log.segment.bytes = 104857600transactional.id.expiration.ms = 604800000unclean.leader.election.enable = falseunstable.api.versions.enable = falseunstable.metadata.versions.enable = falsezookeeper.clientCnxnSocket = nullzookeeper.connect = localhost:2181zookeeper.connection.timeout.ms = 18000zookeeper.max.in.flight.requests = 10zookeeper.metadata.migration.enable = falsezookeeper.metadata.migration.min.batch.size = 200zookeeper.session.timeout.ms = 18000zookeeper.set.acl = falsezookeeper.ssl.cipher.suites = nullzookeeper.ssl.client.enable = falsezookeeper.ssl.crl.enable = falsezookeeper.ssl.enabled.protocols = nullzookeeper.ssl.endpoint.identification.algorithm = HTTPSzookeeper.ssl.keystore.location = nullzookeeper.ssl.keystore.password = nullzookeeper.ssl.keystore.type = nullzookeeper.ssl.ocsp.enable = falsezookeeper.ssl.protocol = TLSv1.2zookeeper.ssl.truststore.location = nullzookeeper.ssl.truststore.password = nullzookeeper.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)

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 %