Kafka伪集群环境部署

一、准备工作

1.下载kafka_2.13-2.8.0.tgz安装包

2.下载jdk-8u301-linux-x64.tar.gz

3.操作系统SUSE_12/CentOS7

【注：上传至kafka用户下的software目录中

二、安装前操作 1. 创建kafka用户、组和密码并登录kafka用户

linux-rxfb:~ # groupadd kafka

linux-rxfb:~ # useradd -g kafka -d /home/kafka -m kafka

linux-rxfb:~ # passwd kafka

【加强密码】

linux-rxfb:~ # su - kafka

2. 创建kafka日志路径

kafka@linux-rxfb:~> mkdir /data/kafka/logs/kafka-2.8.0 -p

# kafka日志节点存放路径
kafka@linux-rxfb:~> mkdir /data/kafka/logs/kafka-2.8.0/{7281,7282,7283}

3. 创建zookeeper日志路径

kafka@linux-rxfb:~> mkdir /data/kafka/logs/zookeeper -p

# zookeeper日志节点路径
kafka@linux-rxfb:~> mkdir /data/kafka/logs/zookeeper/{7181,7182,7183}

4. 创建zookeeper的myid路径

# zookeeper三个节点存放myid的路径
kafka@linux-rxfb:~> mkdir /data/kafka/logs/zookeeper/data/{7181,7182,7183} -p

kafka@linux-rxfb:~> echo 1 > /data/kafka/logs/zookeeper/data/7181/myid
kafka@linux-rxfb:~> echo 2 > /data/kafka/logs/zookeeper/data/7182/myid
kafka@linux-rxfb:~> echo 3 > /data/kafka/logs/zookeeper/data/7183/myid

5. 创建software存放路径

kafka@linux-rxfb:~> mkdir software

#【注：创建完后上传安装包】

6. 部署Java_1.8.0环境

kafka@linux-rxfb:~> tar zxf ./software/jdk-8u301-linux-x64.tar.gz -C ./

kafka@linux-rxfb:~> touch .bash_profile

kafka@linux-rxfb:~> vi .bash_profile 

export JAVA_HOME=/home/kafka/jdk1.8.0_301
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar

kafka@linux-rxfb:~> source .bash_profile

kafka@linux-rxfb:~> java -version
java version "1.8.0_301"
Java(TM) SE Runtime Environment (build 1.8.0_301-b09)
Java HotSpot(TM) 64-Bit Server VM (build 25.301-b09, mixed mode)

三、配置zookeeper 1. 编辑zookeeper配置文件

# 这里配置三个节点分别为7181、7182、7183
kafka@linux-rxfb:~> cd kafka_2.13-2.8.0/config/

kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> cp zookeeper.properties zookeeper.properties_7181 # 先复制出一个配置文件进行修改

kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> vi zookeeper.properties_7181
======================
# 修改配置如下：
# 这个时间是作为 Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔, 也就是每个 tickTime 时间就会发送一个心跳
dataDir=/data/kafka/logs/zookeeper/data/7181
# zookeeper日志存放路径
dataLogDir=/data/kafka/logs/zookeeper/7181

# 客户端连接 Zookeeper 服务器的端口, Zookeeper 会监听这个端口，接受客户端的访问请求
clientPort=7181

# 最大客户端连接数配置100, 结合需求进行调整
maxClientCnxns=100

# 这个时间是作为 Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔, 也就是每个 tickTime 时间就会发送一个心跳
tickTime=2000

# Zookeeper 接受客户端初始化连接时最长能忍受多少个心跳时间间隔数
# 当已经超过 10 个心跳的时间（也就是 tickTime）长度后 Zookeeper 服务器还没有收到客户端的返回信息, 那么表明这个客户端连接失败
# 总的时间长度就是 5*2000=10 秒
initLimit=10 # 默认限制10

# 这个配置项标识 Leader 与 Follower 之间发送消息, 请求和应答时间长度, 最长不能超过多少个 tickTime 的时间长度, 总的时间长度就是 5*2000=4 秒
syncLimit=5 # 同步限制5

# server.A=B：C：D：
# 其中 A 是一个数字,表示这个是第几号服务器
# B 是这个服务器的 ip 地址
# C 与Leader 服务器交换信息的端口
# D选举端口，选出一个新的 Leader
server.1=192.168.19.134:12887:13887
server.2=192.168.19.134:12888:13888
server.3=192.168.19.134:12889:13889

# zookeeper的SASL配置
authProvider.1=org.apache.zookeeper.server.auth.SASLAuthenticationProvider
requireClientAuthScheme=sasl
jaasLoginRenew=3600000
【配置完保存退出】
======================
# 复制出剩余节点配置并修改对应的节点即可
kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> cp zookeeper.properties_7181 zookeeper.properties_7182

kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> cp zookeeper.properties_7181 zookeeper.properties_7183

# 修改如下：
kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> vi zookeeper.properties_7182
dataDir=/data/kafka/logs/zookeeper/data/7182
dataLogDir=/data/kafka/logs/zookeeper/7182
clientPort=7182

kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> vi zookeeper.properties_7183
dataDir=/data/kafka/logs/zookeeper/data/7183
dataLogDir=/data/kafka/logs/zookeeper/7183
clientPort=7183

2. 创建并编辑zookeeper认证文件

# 自定义文件，名称可随便起，此处定义为：zookeeper_jaas.conf
kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> touch zookeeper_jaas.conf

kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> vi zookeeper_jaas.conf
# 新增如下：
Server {
       org.apache.zookeeper.server.auth.DigestLoginModule required
       # 用于zookeeper之间连接认证
       user_admin="XZsTD&$pD4j4sG5Y"
       # 用于kafka连接zookeeper认证
       user_kafka="$MRS4HKfFBVszqBS"
       ;
};
Client {
       org.apache.zookeeper.server.auth.DigestLoginModule required
       # 客户端连接zookeeper之间连接校验，校验Server中的user_admin
       username="admin"
       password="XZsTD&$pD4j4sG5Y"
       ;
};
#【配置完保存退出】

四、配置kafka 1. 编辑kafka配置文件

# 这里配置三个节点分别为7281、7282、7283
kafka@linux-rxfb:~> cd kafka_2.13-2.8.0/config/

kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> cp server.properties server.properties_7281

kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> vi server.properties_7281
======================
# 修改如下：
broker.id=1
listeners=SASL_PLAINTEXT://192.168.19.134:7281
advertised.listeners=SASL_PLAINTEXT://192.168.19.134:7281
log.dirs=/data/kafka/logs/kafka-2.8.0/7281
log.retention.hours=48
zookeeper.connect=192.168.19.134:7181,192.168.19.134:7182,192.168.19.134:7183
default.replication.factor=3
delete.topic.enable=true
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN
=======================
# 复制出剩余节点配置并修改对应的节点即可
kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> cp server.properties_7281 server.properties_7282

kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> cp server.properties_7281 server.properties_7283

# 修改如下：
kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> vi server.properties_7282
broker.id=2
listeners=SASL_PLAINTEXT://192.168.19.134:7282
advertised.listeners=SASL_PLAINTEXT://192.168.19.134:7282
log.dirs=/data/kafka/logs/kafka-2.8.0/7282

kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> vi server.properties_7283
broker.id=3
listeners=SASL_PLAINTEXT://192.168.19.134:7283
advertised.listeners=SASL_PLAINTEXT://192.168.19.134:7283
log.dirs=/data/kafka/logs/kafka-2.8.0/7283

2. 创建并编辑kafka认证文件

# 自定义文件，名称可随便起，此处定义为：kafka_jaas.conf
kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> touch kafka_jaas.conf

kafka@linux-rxfb:~/kafka_2.13-2.8.0/config> vi kafka_jaas.conf
# 新增如下：
KafkaServer{
    org.apache.kafka.common.security.plain.PlainLoginModule required
    # kafka管理用户
    username="kafka"
    # kafka管理密码
    password="$MRS4HKfFBVszqBS"
    # kafka用户及密码（因kafka对接zookeeper是直连账号密码必须一致，否则会出现校验失败的情况）
    user_kafka="$MRS4HKfFBVszqBS"
    user_wxtest="Rfs1Kxd7XPM9x5&A"
    ;
};

Client{
    # 连接zookeeper配置，账号密码对应zookeeper_jaas.conf中的Server配置
    org.apache.zookeeper.server.auth.DigestLoginModule required
    username="kafka"
    password="$MRS4HKfFBVszqBS"
    ;
};

五、配置启动脚本 1. 创建zookeeper启动脚本

kafka@linux-rxfb:~> mkdir yunwei

kafka@linux-rxfb:~/yunwei> vi zookeeper_start_7181.sh 
#!/bin/bash
#

export JAVA_HOME="/home/kafka/jdk1.8.0_301"
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar

export KAFKA_HOME="/home/kafka/kafka_2.13-2.8.0"
export KAFKA_OPTS="-Djava.security.auth.login.config=$KAFKA_HOME/config/zookeeper_jaas.conf"

cd $KAFKA_HOME
nohup ./bin/zookeeper-server-start.sh config/zookeeper.properties_7181 >> /data/kafka/logs/zookeeper/7181/zookeeper.log &
tail -f /data/kafka/logs/zookeeper/7181/zookeeper.log

# 复制出剩余节点配置并修改对应的节点即可
kafka@linux-rxfb:~/yunwei> cp zookeeper_start_7181.sh zookeeper_start_7182.sh 
#!/bin/bash
#

export JAVA_HOME="/home/kafka/jdk1.8.0_301"
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar

export KAFKA_HOME="/home/kafka/kafka_2.13-2.8.0"
export KAFKA_OPTS="-Djava.security.auth.login.config=$KAFKA_HOME/config/zookeeper_jaas.conf"

cd $KAFKA_HOME
nohup ./bin/zookeeper-server-start.sh config/zookeeper.properties_7182 >> /data/kafka/logs/zookeeper/7182/zookeeper.log &
tail -f /data/kafka/logs/zookeeper/7182/zookeeper.log

kafka@linux-rxfb:~/yunwei> cp zookeeper_start_7181.sh zookeeper_start_7183.sh
#!/bin/bash
#

export JAVA_HOME="/home/kafka/jdk1.8.0_301"
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar

export KAFKA_HOME="/home/kafka/kafka_2.13-2.8.0"
export KAFKA_OPTS="-Djava.security.auth.login.config=$KAFKA_HOME/config/zookeeper_jaas.conf"

cd $KAFKA_HOME
nohup ./bin/zookeeper-server-start.sh config/zookeeper.properties_7183 >> /data/kafka/logs/zookeeper/7183/zookeeper.log &
tail -f /data/kafka/logs/zookeeper/7183/zookeeper.log

2. 创建kafka启动脚本

kafka@linux-rxfb:~/yunwei> vi kafka_start_7281.sh
#!/bin/bash
#

export JAVA_HOME="/home/kafka/jdk1.8.0_301"
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar

export KAFKA_HOME="/home/kafka/kafka_2.13-2.8.0"
export KAFKA_OPTS="-Djava.security.auth.login.config=$KAFKA_HOME/config/kafka_jaas.conf"

cd $KAFKA_HOME
nohup ./bin/kafka-server-start.sh config/server.properties_7281 >> /data/kafka/logs/kafka-2.8.0/7281/kafka.log &
tail -f /data/kafka/logs/kafka-2.8.0/7281/kafka.log


kafka@linux-rxfb:~/yunwei> vi kafka_start_7281.sh kafka_start_7282.sh
#!/bin/bash
#

export JAVA_HOME="/home/kafka/jdk1.8.0_301"
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar

export KAFKA_HOME="/home/kafka/kafka_2.13-2.8.0"
export KAFKA_OPTS="-Djava.security.auth.login.config=$KAFKA_HOME/config/kafka_jaas.conf"

cd $KAFKA_HOME
nohup ./bin/kafka-server-start.sh config/server.properties_7282 >> /data/kafka/logs/kafka-2.8.0/7282/kafka.log &
tail -f /data/kafka/logs/kafka-2.8.0/7282/kafka.log


kafka@linux-rxfb:~/yunwei> vi kafka_start_7281.sh kafka_start_7283.sh
#!/bin/bash
#

export JAVA_HOME="/home/kafka/jdk1.8.0_301"
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar

export KAFKA_HOME="/home/kafka/kafka_2.13-2.8.0"
export KAFKA_OPTS="-Djava.security.auth.login.config=$KAFKA_HOME/config/kafka_jaas.conf"

cd $KAFKA_HOME
nohup ./bin/kafka-server-start.sh config/server.properties_7283 >> /data/kafka/logs/kafka-2.8.0/7283/kafka.log &
tail -f /data/kafka/logs/kafka-2.8.0/7283/kafka.log

六、验证服务 1.启动zookeeper

必须首先启动zookeeper

a. 启动zookeeper-node-7181

kafka@linux-rxfb:~> cd yunwei/

kafka@linux-rxfb:~/yunwei> sh zookeeper_start_7181.sh
redirecting stderr to stdout
[2021-11-08 14:11:51,874] INFO Reading configuration from: config/zookeeper.properties_7181 (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
[2021-11-08 14:11:51,875] WARN config/zookeeper.properties_7181 is relative. Prepend ./ to indicate that you're sure! (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
[2021-11-08 14:11:51,886] INFO clientPortAddress is 0.0.0.0:7181 (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
[2021-11-08 14:11:51,886] INFO secureClientPort is not set (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
[2021-11-08 14:11:51,894] INFO autopurge.snapRetainCount set to 3 (org.apache.zookeeper.server.DatadirCleanupManager)
[2021-11-08 14:11:51,895] INFO autopurge.purgeInterval set to 0 (org.apache.zookeeper.server.DatadirCleanupManager)
[2021-11-08 14:11:51,895] INFO Purge task is not scheduled. (org.apache.zookeeper.server.DatadirCleanupManager)
[2021-11-08 14:11:51,896] INFO Log4j 1.2 jmx support found and enabled. (org.apache.zookeeper.jmx.ManagedUtil)
[2021-11-08 14:11:51,904] INFO Starting quorum peer, myid=1 (org.apache.zookeeper.server.quorum.QuorumPeerMain)
[2021-11-08 14:11:51,918] INFO Using org.apache.zookeeper.server.NIOServerCnxnFactory as server connection factory (org.apache.zookeeper.server.ServerCnxnFactory)
[2021-11-08 14:11:51,924] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
[2021-11-08 14:11:51,925] INFO Server successfully logged in. (org.apache.zookeeper.Login)
[2021-11-08 14:11:51,927] INFO Configuring NIO connection handler with 10s sessionless connection timeout, 1 selector thread(s), 4 worker threads, and 64 kB direct buffers. (org.apache.zookeeper.server.NIOServerCnxnFactory)
[2021-11-08 14:11:51,929] INFO binding to port 0.0.0.0/0.0.0.0:7181 (org.apache.zookeeper.server.NIOServerCnxnFactory)
[2021-11-08 14:11:51,939] INFO zookeeper.snapshot.trust.empty : false (org.apache.zookeeper.server.persistence.FileTxnSnapLog)
[2021-11-08 14:11:51,945] INFO Local sessions disabled (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:11:51,946] INFO Local session upgrading disabled (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:11:51,946] INFO tickTime set to 2000 (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:11:51,946] INFO minSessionTimeout set to 4000 (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:11:51,946] INFO maxSessionTimeout set to 40000 (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:11:51,946] INFO initLimit set to 10 (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:11:51,953] INFO zookeeper.snapshotSizeFactor = 0.33 (org.apache.zookeeper.server.ZKDatabase)
[2021-11-08 14:11:51,955] INFO Using insecure (non-TLS) quorum communication (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:11:51,955] INFO Port unification disabled (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:11:51,955] INFO QuorumPeer communication is not secured! (SASL auth disabled) (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:11:51,955] INFO quorum.cnxn.threads.size set to 20 (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:11:51,959] INFO Snapshotting: 0x0 to /data/kafka/logs/zookeeper/data/7181/version-2/snapshot.0 (org.apache.zookeeper.server.persistence.FileTxnSnapLog)
[2021-11-08 14:11:51,964] INFO currentEpoch not found! Creating with a reasonable default of 0. This should only happen when you are upgrading your installation (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:11:51,966] INFO acceptedEpoch not found! Creating with a reasonable default of 0. This should only happen when you are upgrading your installation (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:11:51,972] INFO Election port bind maximum retries is 3 (org.apache.zookeeper.server.quorum.QuorumCnxManager)
[2021-11-08 14:11:51,976] INFO 1 is accepting connections now, my election bind port: /192.168.19.134:13887 (org.apache.zookeeper.server.quorum.QuorumCnxManager)
[2021-11-08 14:11:51,983] INFO LOOKING (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:11:51,985] INFO New election. My id =  1, proposed zxid=0x0 (org.apache.zookeeper.server.quorum.FastLeaderElection)
[2021-11-08 14:11:51,989] INFO Notification: 2 (message format version), 1 (n.leader), 0x0 (n.zxid), 0x1 (n.round), LOOKING (n.state), 1 (n.sid), 0x0 (n.peerEPoch), LOOKING (my state)0 (n.config version) (org.apache.zookeeper.server.quorum.FastLeaderElection)
[2021-11-08 14:11:52,003] WARN Cannot open channel to 2 at election address /192.168.19.134:13888 (org.apache.zookeeper.server.quorum.QuorumCnxManager)
java.net.ConnectException: Connection refused (Connection refused)
        at java.net.PlainSocketImpl.socketConnect(Native Method)
        at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:476)
        at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:218)
        at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:200)
        at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:394)
        at java.net.Socket.connect(Socket.java:606)
        at org.apache.zookeeper.server.quorum.QuorumCnxManager.initiateConnection(QuorumCnxManager.java:373)
        at org.apache.zookeeper.server.quorum.QuorumCnxManager$QuorumConnectionReqThread.run(QuorumCnxManager.java:436)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)

----【因配置了3个节点必须都起来才不会报错】

b. 启动zookeeper-node-7182

kafka@linux-rxfb:~/yunwei> sh zookeeper_start_7182.sh 
nohup: redirecting stderr to stdout
[2021-11-08 14:12:37,440] INFO Reading configuration from: config/zookeeper.properties_7182 (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
[2021-11-08 14:12:37,442] WARN config/zookeeper.properties_7182 is relative. Prepend ./ to indicate that you're sure! (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
[2021-11-08 14:12:37,447] INFO clientPortAddress is 0.0.0.0:7182 (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
[2021-11-08 14:12:37,447] INFO secureClientPort is not set (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
[2021-11-08 14:12:37,454] INFO autopurge.snapRetainCount set to 3 (org.apache.zookeeper.server.DatadirCleanupManager)
[2021-11-08 14:12:37,454] INFO autopurge.purgeInterval set to 0 (org.apache.zookeeper.server.DatadirCleanupManager)
[2021-11-08 14:12:37,454] INFO Purge task is not scheduled. (org.apache.zookeeper.server.DatadirCleanupManager)
[2021-11-08 14:12:37,457] INFO Log4j 1.2 jmx support found and enabled. (org.apache.zookeeper.jmx.ManagedUtil)
[2021-11-08 14:12:37,468] INFO Starting quorum peer, myid=2 (org.apache.zookeeper.server.quorum.QuorumPeerMain)
[2021-11-08 14:12:37,473] INFO Using org.apache.zookeeper.server.NIOServerCnxnFactory as server connection factory (org.apache.zookeeper.server.ServerCnxnFactory)
[2021-11-08 14:12:37,478] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
[2021-11-08 14:12:37,480] INFO Server successfully logged in. (org.apache.zookeeper.Login)
[2021-11-08 14:12:37,481] INFO Configuring NIO connection handler with 10s sessionless connection timeout, 1 selector thread(s), 4 worker threads, and 64 kB direct buffers. (org.apache.zookeeper.server.NIOServerCnxnFactory)
[2021-11-08 14:12:37,485] INFO binding to port 0.0.0.0/0.0.0.0:7182 (org.apache.zookeeper.server.NIOServerCnxnFactory)
[2021-11-08 14:12:37,495] INFO zookeeper.snapshot.trust.empty : false (org.apache.zookeeper.server.persistence.FileTxnSnapLog)
[2021-11-08 14:12:37,501] INFO Local sessions disabled (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:12:37,501] INFO Local session upgrading disabled (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:12:37,501] INFO tickTime set to 2000 (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:12:37,501] INFO minSessionTimeout set to 4000 (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:12:37,501] INFO maxSessionTimeout set to 40000 (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:12:37,501] INFO initLimit set to 10 (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:12:37,509] INFO zookeeper.snapshotSizeFactor = 0.33 (org.apache.zookeeper.server.ZKDatabase)
[2021-11-08 14:12:37,510] INFO Using insecure (non-TLS) quorum communication (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:12:37,510] INFO Port unification disabled (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:12:37,510] INFO QuorumPeer communication is not secured! (SASL auth disabled) (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:12:37,510] INFO quorum.cnxn.threads.size set to 20 (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:12:37,512] INFO Snapshotting: 0x0 to /data/kafka/logs/zookeeper/data/7182/version-2/snapshot.0 (org.apache.zookeeper.server.persistence.FileTxnSnapLog)
[2021-11-08 14:12:37,517] INFO currentEpoch not found! Creating with a reasonable default of 0. This should only happen when you are upgrading your installation (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:12:37,519] INFO acceptedEpoch not found! Creating with a reasonable default of 0. This should only happen when you are upgrading your installation (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:12:37,526] INFO Election port bind maximum retries is 3 (org.apache.zookeeper.server.quorum.QuorumCnxManager)
[2021-11-08 14:12:37,530] INFO 2 is accepting connections now, my election bind port: /192.168.19.134:13888 (org.apache.zookeeper.server.quorum.QuorumCnxManager)
[2021-11-08 14:12:37,538] INFO LOOKING (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:12:37,545] INFO New election. My id =  2, proposed zxid=0x0 (org.apache.zookeeper.server.quorum.FastLeaderElection)
[2021-11-08 14:12:37,552] INFO Notification: 2 (message format version), 2 (n.leader), 0x0 (n.zxid), 0x1 (n.round), LOOKING (n.state), 2 (n.sid), 0x0 (n.peerEPoch), LOOKING (my state)0 (n.config version) (org.apache.zookeeper.server.quorum.FastLeaderElection)
[2021-11-08 14:12:37,568] WARN Cannot open channel to 3 at election address /192.168.19.134:13889 (org.apache.zookeeper.server.quorum.QuorumCnxManager)
java.net.ConnectException: Connection refused (Connection refused)
        at java.net.PlainSocketImpl.socketConnect(Native Method)
        at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:476)
        at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:218)
        at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:200)
        at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:394)
        at java.net.Socket.connect(Socket.java:606)
        at org.apache.zookeeper.server.quorum.QuorumCnxManager.initiateConnection(QuorumCnxManager.java:373)
        at org.apache.zookeeper.server.quorum.QuorumCnxManager$QuorumConnectionReqThread.run(QuorumCnxManager.java:436)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
[2021-11-08 14:12:37,576] INFO Notification: 2 (message format version), 1 (n.leader), 0x0 (n.zxid), 0x1 (n.round), LOOKING (n.state), 1 (n.sid), 0x0 (n.peerEPoch), LOOKING (my state)0 (n.config version) (org.apache.zookeeper.server.quorum.FastLeaderElection)
[2021-11-08 14:12:37,576] INFO Notification: 2 (message format version), 2 (n.leader), 0x0 (n.zxid), 0x1 (n.round), LOOKING (n.state), 1 (n.sid), 0x0 (n.peerEPoch), LOOKING (my state)0 (n.config version) (org.apache.zookeeper.server.quorum.FastLeaderElection)
[2021-11-08 14:12:37,778] INFO LEADING (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:12:37,781] INFO TCP NoDelay set to: true (org.apache.zookeeper.server.quorum.Leader)
[2021-11-08 14:12:37,781] INFO zookeeper.leader.maxConcurrentSnapshots = 10 (org.apache.zookeeper.server.quorum.Leader)
[2021-11-08 14:12:37,781] INFO zookeeper.leader.maxConcurrentSnapshotTimeout = 5 (org.apache.zookeeper.server.quorum.Leader)
[2021-11-08 14:12:37,786] INFO Server environment:zookeeper.version=3.5.9-83df9301aa5c2a5d284a9940177808c01bc35cef, built on 01/06/2021 20:03 GMT (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,787] INFO Server environment:host.name=linux-rxfb (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,787] INFO Server environment:java.version=1.8.0_301 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,787] INFO Server environment:java.vendor=Oracle Corporation (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,787] INFO Server environment:java.home=/home/kafka/jdk1.8.0_301/jre (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,788] INFO Server environment:java.class.path=.:/home/kafka/jdk1.8.0_301/lib/dt.jar:/home/kafka/jdk1.8.0_301/lib/tools.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/activation-1.1.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/aopalliance-repackaged-2.6.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/argparse4j-0.7.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/audience-annotations-0.5.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/commons-cli-1.4.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/commons-lang3-3.8.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-api-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-basic-auth-extension-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-file-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-json-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-mirror-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-mirror-client-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-runtime-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-transforms-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/hk2-api-2.6.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/hk2-locator-2.6.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/hk2-utils-2.6.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-annotations-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-core-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-databind-2.10.5.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-dataformat-csv-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-datatype-jdk8-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-jaxrs-base-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-jaxrs-json-provider-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-module-jaxb-annotations-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-module-paranamer-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-module-scala_2.13-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.activation-api-1.2.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.annotation-api-1.3.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.inject-2.6.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.validation-api-2.0.2.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.ws.rs-api-2.1.6.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.xml.bind-api-2.3.2.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/javassist-3.27.0-GA.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/javax.servlet-api-3.1.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/javax.ws.rs-api-2.1.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jaxb-api-2.3.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-client-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-common-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-container-servlet-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-container-servlet-core-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-hk2-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-media-jaxb-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-server-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-client-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-continuation-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-http-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-io-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-security-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-server-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-servlet-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-servlets-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-util-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-util-ajax-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jline-3.12.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jopt-simple-5.0.4.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka_2.13-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka_2.13-2.8.0-sources.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-clients-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-log4j-appender-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-metadata-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-raft-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-shell-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-streams-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-streams-examples-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-streams-scala_2.13-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-streams-test-utils-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-tools-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/log4j-1.2.17.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/lz4-java-1.7.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/maven-artifact-3.6.3.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/metrics-core-2.2.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-buffer-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-codec-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-common-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-handler-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-resolver-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-transport-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-transport-native-epoll-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-transport-native-unix-common-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/osgi-resource-locator-1.0.3.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/paranamer-2.8.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/plexus-utils-3.2.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/reflections-0.9.12.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/rocksdbjni-5.18.4.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/scala-collection-compat_2.13-2.3.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/scala-java8-compat_2.13-0.9.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/scala-library-2.13.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/scala-logging_2.13-3.9.2.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/scala-reflect-2.13.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/slf4j-api-1.7.30.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/slf4j-log4j12-1.7.30.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/snappy-java-1.1.8.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/zookeeper-3.5.9.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/zookeeper-jute-3.5.9.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/zstd-jni-1.4.9-1.jar (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,788] INFO Server environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,788] INFO Server environment:java.io.tmpdir=/tmp (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,789] INFO Server environment:java.compiler= (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,789] INFO Server environment:os.name=Linux (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,789] INFO Server environment:os.arch=amd64 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,789] INFO Server environment:os.version=4.12.14-94.41-default (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,789] INFO Server environment:user.name=kafka (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,789] INFO Server environment:user.home=/home/kafka (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,789] INFO Server environment:user.dir=/home/kafka/kafka_2.13-2.8.0 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,789] INFO Server environment:os.memory.free=505MB (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,789] INFO Server environment:os.memory.max=512MB (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,789] INFO Server environment:os.memory.total=512MB (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,791] INFO minSessionTimeout set to 4000 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,791] INFO maxSessionTimeout set to 40000 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,792] INFO Created server with tickTime 2000 minSessionTimeout 4000 maxSessionTimeout 40000 datadir /data/kafka/logs/zookeeper/7182/version-2 snapdir /data/kafka/logs/zookeeper/data/7182/version-2 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:12:37,794] INFO LEADING - LEADER ELECTION TOOK - 16 MS (org.apache.zookeeper.server.quorum.Leader)
[2021-11-08 14:12:37,796] INFO Snapshotting: 0x0 to /data/kafka/logs/zookeeper/data/7182/version-2/snapshot.0 (org.apache.zookeeper.server.persistence.FileTxnSnapLog)
[2021-11-08 14:12:37,807] INFO Follower sid: 1 : info : 192.168.19.134:12887:13887:participant (org.apache.zookeeper.server.quorum.LearnerHandler)
[2021-11-08 14:12:37,809] INFO Dynamic reconfig is disabled, we don't store the last seen config. (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:12:37,810] INFO On disk txn sync enabled with snapshotSizeFactor 0.33 (org.apache.zookeeper.server.ZKDatabase)
[2021-11-08 14:12:37,811] INFO Synchronizing with Follower sid: 1 maxCommittedLog=0x0 minCommittedLog=0x0 lastProcessedZxid=0x0 peerLastZxid=0x0 (org.apache.zookeeper.server.quorum.LearnerHandler)
[2021-11-08 14:12:37,811] INFO Sending DIFF zxid=0x0 for peer sid: 1 (org.apache.zookeeper.server.quorum.LearnerHandler)
[2021-11-08 14:12:37,819] INFO Have quorum of supporters, sids: [[1, 2]]; starting up and setting last processed zxid: 0x100000000 (org.apache.zookeeper.server.quorum.Leader)
[2021-11-08 14:12:37,819] INFO Dynamic reconfig feature is disabled, skip designatedLeader calculation and reconfig processing. (org.apache.zookeeper.server.quorum.Leader)
[2021-11-08 14:12:37,827] INFO Configuring CommitProcessor with 2 worker threads. (org.apache.zookeeper.server.quorum.CommitProcessor)
[2021-11-08 14:12:37,841] INFO PrepRequestProcessor (sid:2) started, reconfigEnabled=false (org.apache.zookeeper.server.PrepRequestProcessor)
[2021-11-08 14:12:37,842] INFO Using checkIntervalMs=60000 maxPerMinute=10000 (org.apache.zookeeper.server.ContainerManager)

c. 启动zookeeper-node-7183

kafka@linux-rxfb:~/yunwei> sh zookeeper_start_7183.sh 
nohup: redirecting stderr to stdout
[2021-11-08 14:13:12,619] INFO Reading configuration from: config/zookeeper.properties_7183 (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
[2021-11-08 14:13:12,622] WARN config/zookeeper.properties_7183 is relative. Prepend ./ to indicate that you're sure! (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
[2021-11-08 14:13:12,627] INFO clientPortAddress is 0.0.0.0:7183 (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
[2021-11-08 14:13:12,627] INFO secureClientPort is not set (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
[2021-11-08 14:13:12,634] INFO autopurge.snapRetainCount set to 3 (org.apache.zookeeper.server.DatadirCleanupManager)
[2021-11-08 14:13:12,634] INFO autopurge.purgeInterval set to 0 (org.apache.zookeeper.server.DatadirCleanupManager)
[2021-11-08 14:13:12,635] INFO Purge task is not scheduled. (org.apache.zookeeper.server.DatadirCleanupManager)
[2021-11-08 14:13:12,637] INFO Log4j 1.2 jmx support found and enabled. (org.apache.zookeeper.jmx.ManagedUtil)
[2021-11-08 14:13:12,648] INFO Starting quorum peer, myid=3 (org.apache.zookeeper.server.quorum.QuorumPeerMain)
[2021-11-08 14:13:12,653] INFO Using org.apache.zookeeper.server.NIOServerCnxnFactory as server connection factory (org.apache.zookeeper.server.ServerCnxnFactory)
[2021-11-08 14:13:12,658] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
[2021-11-08 14:13:12,660] INFO Server successfully logged in. (org.apache.zookeeper.Login)
[2021-11-08 14:13:12,662] INFO Configuring NIO connection handler with 10s sessionless connection timeout, 1 selector thread(s), 4 worker threads, and 64 kB direct buffers. (org.apache.zookeeper.server.NIOServerCnxnFactory)
[2021-11-08 14:13:12,666] INFO binding to port 0.0.0.0/0.0.0.0:7183 (org.apache.zookeeper.server.NIOServerCnxnFactory)
[2021-11-08 14:13:12,674] INFO zookeeper.snapshot.trust.empty : false (org.apache.zookeeper.server.persistence.FileTxnSnapLog)
[2021-11-08 14:13:12,681] INFO Local sessions disabled (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:13:12,681] INFO Local session upgrading disabled (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:13:12,681] INFO tickTime set to 2000 (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:13:12,682] INFO minSessionTimeout set to 4000 (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:13:12,682] INFO maxSessionTimeout set to 40000 (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:13:12,682] INFO initLimit set to 10 (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:13:12,689] INFO zookeeper.snapshotSizeFactor = 0.33 (org.apache.zookeeper.server.ZKDatabase)
[2021-11-08 14:13:12,691] INFO Using insecure (non-TLS) quorum communication (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:13:12,691] INFO Port unification disabled (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:13:12,691] INFO QuorumPeer communication is not secured! (SASL auth disabled) (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:13:12,692] INFO quorum.cnxn.threads.size set to 20 (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:13:12,694] INFO Snapshotting: 0x0 to /data/kafka/logs/zookeeper/data/7183/version-2/snapshot.0 (org.apache.zookeeper.server.persistence.FileTxnSnapLog)
[2021-11-08 14:13:12,699] INFO currentEpoch not found! Creating with a reasonable default of 0. This should only happen when you are upgrading your installation (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:13:12,702] INFO acceptedEpoch not found! Creating with a reasonable default of 0. This should only happen when you are upgrading your installation (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:13:12,709] INFO Election port bind maximum retries is 3 (org.apache.zookeeper.server.quorum.QuorumCnxManager)
[2021-11-08 14:13:12,714] INFO 3 is accepting connections now, my election bind port: /192.168.19.134:13889 (org.apache.zookeeper.server.quorum.QuorumCnxManager)
[2021-11-08 14:13:12,720] INFO LOOKING (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:13:12,721] INFO New election. My id =  3, proposed zxid=0x0 (org.apache.zookeeper.server.quorum.FastLeaderElection)
[2021-11-08 14:13:12,726] INFO Notification: 2 (message format version), 3 (n.leader), 0x0 (n.zxid), 0x1 (n.round), LOOKING (n.state), 3 (n.sid), 0x0 (n.peerEPoch), LOOKING (my state)0 (n.config version) (org.apache.zookeeper.server.quorum.FastLeaderElection)
[2021-11-08 14:13:12,742] INFO Notification: 2 (message format version), 2 (n.leader), 0x0 (n.zxid), 0x1 (n.round), LOOKING (n.state), 2 (n.sid), 0x0 (n.peerEPoch), LOOKING (my state)0 (n.config version) (org.apache.zookeeper.server.quorum.FastLeaderElection)
[2021-11-08 14:13:12,744] INFO Notification: 2 (message format version), 2 (n.leader), 0x0 (n.zxid), 0x1 (n.round), LEADING (n.state), 2 (n.sid), 0x1 (n.peerEPoch), LOOKING (my state)0 (n.config version) (org.apache.zookeeper.server.quorum.FastLeaderElection)
[2021-11-08 14:13:12,744] INFO Notification: 2 (message format version), 2 (n.leader), 0x0 (n.zxid), 0x1 (n.round), LOOKING (n.state), 1 (n.sid), 0x0 (n.peerEPoch), LOOKING (my state)0 (n.config version) (org.apache.zookeeper.server.quorum.FastLeaderElection)
[2021-11-08 14:13:12,745] INFO Notification: 2 (message format version), 2 (n.leader), 0x0 (n.zxid), 0x1 (n.round), FOLLOWING (n.state), 1 (n.sid), 0x1 (n.peerEPoch), LOOKING (my state)0 (n.config version) (org.apache.zookeeper.server.quorum.FastLeaderElection)
[2021-11-08 14:13:12,746] INFO FOLLOWING (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:13:12,748] INFO TCP NoDelay set to: true (org.apache.zookeeper.server.quorum.Learner)
[2021-11-08 14:13:12,751] INFO Server environment:zookeeper.version=3.5.9-83df9301aa5c2a5d284a9940177808c01bc35cef, built on 01/06/2021 20:03 GMT (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,751] INFO Server environment:host.name=linux-rxfb (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,751] INFO Server environment:java.version=1.8.0_301 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,751] INFO Server environment:java.vendor=Oracle Corporation (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,751] INFO Server environment:java.home=/home/kafka/jdk1.8.0_301/jre (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,751] INFO Server environment:java.class.path=.:/home/kafka/jdk1.8.0_301/lib/dt.jar:/home/kafka/jdk1.8.0_301/lib/tools.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/activation-1.1.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/aopalliance-repackaged-2.6.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/argparse4j-0.7.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/audience-annotations-0.5.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/commons-cli-1.4.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/commons-lang3-3.8.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-api-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-basic-auth-extension-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-file-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-json-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-mirror-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-mirror-client-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-runtime-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-transforms-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/hk2-api-2.6.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/hk2-locator-2.6.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/hk2-utils-2.6.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-annotations-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-core-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-databind-2.10.5.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-dataformat-csv-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-datatype-jdk8-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-jaxrs-base-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-jaxrs-json-provider-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-module-jaxb-annotations-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-module-paranamer-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-module-scala_2.13-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.activation-api-1.2.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.annotation-api-1.3.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.inject-2.6.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.validation-api-2.0.2.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.ws.rs-api-2.1.6.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.xml.bind-api-2.3.2.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/javassist-3.27.0-GA.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/javax.servlet-api-3.1.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/javax.ws.rs-api-2.1.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jaxb-api-2.3.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-client-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-common-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-container-servlet-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-container-servlet-core-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-hk2-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-media-jaxb-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-server-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-client-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-continuation-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-http-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-io-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-security-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-server-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-servlet-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-servlets-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-util-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-util-ajax-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jline-3.12.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jopt-simple-5.0.4.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka_2.13-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka_2.13-2.8.0-sources.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-clients-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-log4j-appender-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-metadata-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-raft-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-shell-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-streams-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-streams-examples-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-streams-scala_2.13-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-streams-test-utils-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-tools-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/log4j-1.2.17.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/lz4-java-1.7.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/maven-artifact-3.6.3.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/metrics-core-2.2.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-buffer-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-codec-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-common-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-handler-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-resolver-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-transport-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-transport-native-epoll-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-transport-native-unix-common-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/osgi-resource-locator-1.0.3.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/paranamer-2.8.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/plexus-utils-3.2.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/reflections-0.9.12.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/rocksdbjni-5.18.4.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/scala-collection-compat_2.13-2.3.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/scala-java8-compat_2.13-0.9.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/scala-library-2.13.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/scala-logging_2.13-3.9.2.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/scala-reflect-2.13.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/slf4j-api-1.7.30.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/slf4j-log4j12-1.7.30.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/snappy-java-1.1.8.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/zookeeper-3.5.9.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/zookeeper-jute-3.5.9.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/zstd-jni-1.4.9-1.jar (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,752] INFO Server environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,752] INFO Server environment:java.io.tmpdir=/tmp (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,752] INFO Server environment:java.compiler= (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,752] INFO Server environment:os.name=Linux (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,752] INFO Server environment:os.arch=amd64 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,752] INFO Server environment:os.version=4.12.14-94.41-default (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,752] INFO Server environment:user.name=kafka (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,752] INFO Server environment:user.home=/home/kafka (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,752] INFO Server environment:user.dir=/home/kafka/kafka_2.13-2.8.0 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,752] INFO Server environment:os.memory.free=505MB (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,752] INFO Server environment:os.memory.max=512MB (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,752] INFO Server environment:os.memory.total=512MB (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,753] INFO minSessionTimeout set to 4000 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,753] INFO maxSessionTimeout set to 40000 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,754] INFO Created server with tickTime 2000 minSessionTimeout 4000 maxSessionTimeout 40000 datadir /data/kafka/logs/zookeeper/7183/version-2 snapdir /data/kafka/logs/zookeeper/data/7183/version-2 (org.apache.zookeeper.server.ZooKeeperServer)
[2021-11-08 14:13:12,754] INFO FOLLOWING - LEADER ELECTION TOOK - 8 MS (org.apache.zookeeper.server.quorum.Learner)
[2021-11-08 14:13:12,762] INFO Getting a snapshot from leader 0x100000000 (org.apache.zookeeper.server.quorum.Learner)
[2021-11-08 14:13:12,767] INFO Learner received NEWLEADER message (org.apache.zookeeper.server.quorum.Learner)
[2021-11-08 14:13:12,767] INFO Dynamic reconfig is disabled, we don't store the last seen config. (org.apache.zookeeper.server.quorum.QuorumPeer)
[2021-11-08 14:13:12,767] INFO Snapshotting: 0x100000000 to /data/kafka/logs/zookeeper/data/7183/version-2/snapshot.100000000 (org.apache.zookeeper.server.persistence.FileTxnSnapLog)
[2021-11-08 14:13:12,770] INFO Learner received UPTODATE message (org.apache.zookeeper.server.quorum.Learner)
[2021-11-08 14:13:12,775] INFO Configuring CommitProcessor with 2 worker threads. (org.apache.zookeeper.server.quorum.CommitProcessor)
-----【此时zookeeper已经正常，报错已经没有了】

1. 启动kafka

随后启动kafka

a. 启动kafka-node-7281

kafka@linux-rxfb:~> cd yunwei/

kafka@linux-rxfb:~/yunwei> sh kafka_start_7281.sh
redirecting stderr to stdout
[2021-11-08 14:22:17,739] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2021-11-08 14:22:17,938] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
[2021-11-08 14:22:17,993] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler)
[2021-11-08 14:22:18,005] INFO starting (kafka.server.KafkaServer)
[2021-11-08 14:22:18,006] INFO Connecting to zookeeper on 192.168.19.134:7181,192.168.19.134:7182,192.168.19.134:7183 (kafka.server.KafkaServer)
[2021-11-08 14:22:18,023] INFO [ZooKeeperClient Kafka server] Initializing a new session to 192.168.19.134:7181,192.168.19.134:7182,192.168.19.134:7183. (kafka.zookeeper.ZooKeeperClient)
[2021-11-08 14:22:18,027] INFO Client environment:zookeeper.version=3.5.9-83df9301aa5c2a5d284a9940177808c01bc35cef, built on 01/06/2021 20:03 GMT (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,027] INFO Client environment:host.name=linux-rxfb (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,027] INFO Client environment:java.version=1.8.0_301 (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,027] INFO Client environment:java.vendor=Oracle Corporation (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,027] INFO Client environment:java.home=/home/kafka/jdk1.8.0_301/jre (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,027] INFO Client environment:java.class.path=.:/home/kafka/jdk1.8.0_301/lib/dt.jar:/home/kafka/jdk1.8.0_301/lib/tools.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/activation-1.1.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/aopalliance-repackaged-2.6.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/argparse4j-0.7.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/audience-annotations-0.5.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/commons-cli-1.4.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/commons-lang3-3.8.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-api-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-basic-auth-extension-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-file-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-json-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-mirror-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-mirror-client-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-runtime-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/connect-transforms-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/hk2-api-2.6.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/hk2-locator-2.6.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/hk2-utils-2.6.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-annotations-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-core-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-databind-2.10.5.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-dataformat-csv-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-datatype-jdk8-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-jaxrs-base-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-jaxrs-json-provider-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-module-jaxb-annotations-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-module-paranamer-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jackson-module-scala_2.13-2.10.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.activation-api-1.2.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.annotation-api-1.3.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.inject-2.6.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.validation-api-2.0.2.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.ws.rs-api-2.1.6.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jakarta.xml.bind-api-2.3.2.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/javassist-3.27.0-GA.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/javax.servlet-api-3.1.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/javax.ws.rs-api-2.1.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jaxb-api-2.3.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-client-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-common-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-container-servlet-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-container-servlet-core-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-hk2-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-media-jaxb-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jersey-server-2.31.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-client-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-continuation-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-http-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-io-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-security-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-server-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-servlet-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-servlets-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-util-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jetty-util-ajax-9.4.39.v20210325.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jline-3.12.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/jopt-simple-5.0.4.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka_2.13-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka_2.13-2.8.0-sources.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-clients-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-log4j-appender-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-metadata-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-raft-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-shell-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-streams-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-streams-examples-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-streams-scala_2.13-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-streams-test-utils-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/kafka-tools-2.8.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/log4j-1.2.17.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/lz4-java-1.7.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/maven-artifact-3.6.3.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/metrics-core-2.2.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-buffer-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-codec-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-common-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-handler-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-resolver-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-transport-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-transport-native-epoll-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/netty-transport-native-unix-common-4.1.62.Final.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/osgi-resource-locator-1.0.3.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/paranamer-2.8.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/plexus-utils-3.2.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/reflections-0.9.12.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/rocksdbjni-5.18.4.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/scala-collection-compat_2.13-2.3.0.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/scala-java8-compat_2.13-0.9.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/scala-library-2.13.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/scala-logging_2.13-3.9.2.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/scala-reflect-2.13.5.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/slf4j-api-1.7.30.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/slf4j-log4j12-1.7.30.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/snappy-java-1.1.8.1.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/zookeeper-3.5.9.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/zookeeper-jute-3.5.9.jar:/home/kafka/kafka_2.13-2.8.0/bin/../libs/zstd-jni-1.4.9-1.jar (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,028] INFO Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,028] INFO Client environment:java.io.tmpdir=/tmp (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,028] INFO Client environment:java.compiler= (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,028] INFO Client environment:os.name=Linux (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,028] INFO Client environment:os.arch=amd64 (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,028] INFO Client environment:os.version=4.12.14-94.41-default (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,028] INFO Client environment:user.name=kafka (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,028] INFO Client environment:user.home=/home/kafka (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,028] INFO Client environment:user.dir=/home/kafka/kafka_2.13-2.8.0 (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,028] INFO Client environment:os.memory.free=1011MB (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,028] INFO Client environment:os.memory.max=1024MB (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,028] INFO Client environment:os.memory.total=1024MB (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,030] INFO Initiating client connection, connectString=192.168.19.134:7181,192.168.19.134:7182,192.168.19.134:7183 sessionTimeout=18000 watcher=kafka.zookeeper.ZooKeeperClient$ZooKeeperClientWatcher$@f6efaab (org.apache.zookeeper.ZooKeeper)
[2021-11-08 14:22:18,033] INFO jute.maxbuffer value is 4194304 Bytes (org.apache.zookeeper.ClientCnxnSocket)
[2021-11-08 14:22:18,036] INFO zookeeper.request.timeout value is 0. feature enabled= (org.apache.zookeeper.ClientCnxn)
[2021-11-08 14:22:18,038] INFO [ZooKeeperClient Kafka server] Waiting until connected. (kafka.zookeeper.ZooKeeperClient)
[2021-11-08 14:22:18,042] INFO Client successfully logged in. (org.apache.zookeeper.Login)
[2021-11-08 14:22:18,043] INFO Client will use DIGEST-MD5 as SASL mechanism. (org.apache.zookeeper.client.ZooKeeperSaslClient)
[2021-11-08 14:22:18,094] INFO Opening socket connection to server linux-rxfb/192.168.19.134:7182. Will attempt to SASL-authenticate using Login Context section 'Client' (org.apache.zookeeper.ClientCnxn)
[2021-11-08 14:22:18,096] INFO Socket connection established, initiating session, client: /192.168.19.134:41800, server: linux-rxfb/192.168.19.134:7182 (org.apache.zookeeper.ClientCnxn)
[2021-11-08 14:22:18,193] INFO Session establishment complete on server linux-rxfb/192.168.19.134:7182, sessionid = 0x20004f99bdb0000, negotiated timeout = 18000 (org.apache.zookeeper.ClientCnxn)
[2021-11-08 14:22:18,197] INFO [ZooKeeperClient Kafka server] Connected. (kafka.zookeeper.ZooKeeperClient)
[2021-11-08 14:22:18,569] INFO [feature-zk-node-event-process-thread]: Starting (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)
[2021-11-08 14:22:18,577] INFO Feature ZK node at path: /feature does not exist (kafka.server.FinalizedFeatureChangeListener)
[2021-11-08 14:22:18,577] INFO Cleared cache (kafka.server.FinalizedFeatureCache)
[2021-11-08 14:22:18,695] INFO Cluster ID = CrUF4nJbQXWkLyUSvh79Kw (kafka.server.KafkaServer)
[2021-11-08 14:22:18,697] WARN No meta.properties file under dir /data/kafka/logs/kafka-2.8.0/7281/meta.properties (kafka.server.BrokermetadataCheckpoint)
[2021-11-08 14:22:18,734] INFO KafkaConfig values: 
        advertised.host.name = null
        advertised.listeners = SASL_PLAINTEXT://192.168.19.134:7281
        advertised.port = null
        alter.config.policy.class.name = null
        alter.log.dirs.replication.quota.window.num = 11
        alter.log.dirs.replication.quota.window.size.seconds = 1
        authorizer.class.name = 
        auto.create.topics.enable = true
        auto.leader.rebalance.enable = true
        background.threads = 10
        broker.heartbeat.interval.ms = 2000
        broker.id = 1
        broker.id.generation.enable = true
        broker.rack = null
        broker.session.timeout.ms = 9000
        client.quota.callback.class = null
        compression.type = producer
        connection.failed.authentication.delay.ms = 100
        connections.max.idle.ms = 600000
        connections.max.reauth.ms = 0
        control.plane.listener.name = null
        controlled.shutdown.enable = true
        controlled.shutdown.max.retries = 3
        controlled.shutdown.retry.backoff.ms = 5000
        controller.listener.names = null
        controller.quorum.append.linger.ms = 25
        controller.quorum.election.backoff.max.ms = 1000
        controller.quorum.election.timeout.ms = 1000
        controller.quorum.fetch.timeout.ms = 2000
        controller.quorum.request.timeout.ms = 2000
        controller.quorum.retry.backoff.ms = 20
        controller.quorum.voters = []
        controller.quota.window.num = 11
        controller.quota.window.size.seconds = 1
        controller.socket.timeout.ms = 30000
        create.topic.policy.class.name = null
        default.replication.factor = 3
        delegation.token.expiry.check.interval.ms = 3600000
        delegation.token.expiry.time.ms = 86400000
        delegation.token.master.key = null
        delegation.token.max.lifetime.ms = 604800000
        delegation.token.secret.key = null
        delete.records.purgatory.purge.interval.requests = 1
        delete.topic.enable = true
        fetch.max.bytes = 57671680
        fetch.purgatory.purge.interval.requests = 1000
        group.initial.rebalance.delay.ms = 0
        group.max.session.timeout.ms = 1800000
        group.max.size = 2147483647
        group.min.session.timeout.ms = 6000
        host.name = 
        initial.broker.registration.timeout.ms = 60000
        inter.broker.listener.name = null
        inter.broker.protocol.version = 2.8-IV1
        kafka.metrics.polling.interval.secs = 10
        kafka.metrics.reporters = []
        leader.imbalance.check.interval.seconds = 300
        leader.imbalance.per.broker.percentage = 10
        listener.security.protocol.map = PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL
        listeners = SASL_PLAINTEXT://192.168.19.134:7281
        log.cleaner.backoff.ms = 15000
        log.cleaner.dedupe.buffer.size = 134217728
        log.cleaner.delete.retention.ms = 86400000
        log.cleaner.enable = true
        log.cleaner.io.buffer.load.factor = 0.9
        log.cleaner.io.buffer.size = 524288
        log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308
        log.cleaner.max.compaction.lag.ms = 9223372036854775807
        log.cleaner.min.cleanable.ratio = 0.5
        log.cleaner.min.compaction.lag.ms = 0
        log.cleaner.threads = 1
        log.cleanup.policy = [delete]
        log.dir = /tmp/kafka-logs
        log.dirs = /data/kafka/logs/kafka-2.8.0/7281
        log.flush.interval.messages = 9223372036854775807
        log.flush.interval.ms = null
        log.flush.offset.checkpoint.interval.ms = 60000
        log.flush.scheduler.interval.ms = 9223372036854775807
        log.flush.start.offset.checkpoint.interval.ms = 60000
        log.index.interval.bytes = 4096
        log.index.size.max.bytes = 10485760
        log.message.downconversion.enable = true
        log.message.format.version = 2.8-IV1
        log.message.timestamp.difference.max.ms = 9223372036854775807
        log.message.timestamp.type = CreateTime
        log.preallocate = false
        log.retention.bytes = -1
        log.retention.check.interval.ms = 300000
        log.retention.hours = 48
        log.retention.minutes = null
        log.retention.ms = null
        log.roll.hours = 168
        log.roll.jitter.hours = 0
        log.roll.jitter.ms = null
        log.roll.ms = null
        log.segment.bytes = 1073741824
        log.segment.delete.delay.ms = 60000
        max.connection.creation.rate = 2147483647
        max.connections = 2147483647
        max.connections.per.ip = 2147483647
        max.connections.per.ip.overrides = 
        max.incremental.fetch.session.cache.slots = 1000
        message.max.bytes = 1048588
        metadata.log.dir = null
        metric.reporters = []
        metrics.num.samples = 2
        metrics.recording.level = INFO
        metrics.sample.window.ms = 30000
        min.insync.replicas = 1
        node.id = -1
        num.io.threads = 8
        num.network.threads = 3
        num.partitions = 1
        num.recovery.threads.per.data.dir = 1
        num.replica.alter.log.dirs.threads = null
        num.replica.fetchers = 1
        offset.metadata.max.bytes = 4096
        offsets.commit.required.acks = -1
        offsets.commit.timeout.ms = 5000
        offsets.load.buffer.size = 5242880
        offsets.retention.check.interval.ms = 600000
        offsets.retention.minutes = 10080
        offsets.topic.compression.codec = 0
        offsets.topic.num.partitions = 50
        offsets.topic.replication.factor = 1
        offsets.topic.segment.bytes = 104857600
        password.encoder.cipher.algorithm = AES/CBC/PKCS5Padding
        password.encoder.iterations = 4096
        password.encoder.key.length = 128
        password.encoder.keyfactory.algorithm = null
        password.encoder.old.secret = null
        password.encoder.secret = null
        port = 9092
        principal.builder.class = null
        process.roles = []
        producer.purgatory.purge.interval.requests = 1000
        queued.max.request.bytes = -1
        queued.max.requests = 500
        quota.consumer.default = 9223372036854775807
        quota.producer.default = 9223372036854775807
        quota.window.num = 11
        quota.window.size.seconds = 1
        replica.fetch.backoff.ms = 1000
        replica.fetch.max.bytes = 1048576
        replica.fetch.min.bytes = 1
        replica.fetch.response.max.bytes = 10485760
        replica.fetch.wait.max.ms = 500
        replica.high.watermark.checkpoint.interval.ms = 5000
        replica.lag.time.max.ms = 30000
        replica.selector.class = null
        replica.socket.receive.buffer.bytes = 65536
        replica.socket.timeout.ms = 30000
        replication.quota.window.num = 11
        replication.quota.window.size.seconds = 1
        request.timeout.ms = 30000
        reserved.broker.max.id = 1000
        sasl.client.callback.handler.class = null
        sasl.enabled.mechanisms = [PLAIN]
        sasl.jaas.config = null
        sasl.kerberos.kinit.cmd = /usr/bin/kinit
        sasl.kerberos.min.time.before.relogin = 60000
        sasl.kerberos.principal.to.local.rules = [DEFAULT]
        sasl.kerberos.service.name = null
        sasl.kerberos.ticket.renew.jitter = 0.05
        sasl.kerberos.ticket.renew.window.factor = 0.8
        sasl.login.callback.handler.class = null
        sasl.login.class = null
        sasl.login.refresh.buffer.seconds = 300
        sasl.login.refresh.min.period.seconds = 60
        sasl.login.refresh.window.factor = 0.8
        sasl.login.refresh.window.jitter = 0.05
        sasl.mechanism.controller.protocol = GSSAPI
        sasl.mechanism.inter.broker.protocol = PLAIN
        sasl.server.callback.handler.class = null
        security.inter.broker.protocol = SASL_PLAINTEXT
        security.providers = null
        socket.connection.setup.timeout.max.ms = 30000
        socket.connection.setup.timeout.ms = 10000
        socket.receive.buffer.bytes = 102400
        socket.request.max.bytes = 104857600
        socket.send.buffer.bytes = 102400
        ssl.cipher.suites = []
        ssl.client.auth = none
        ssl.enabled.protocols = [TLSv1.2]
        ssl.endpoint.identification.algorithm = https
        ssl.engine.factory.class = null
        ssl.key.password = null
        ssl.keymanager.algorithm = SunX509
        ssl.keystore.certificate.chain = null
        ssl.keystore.key = null
        ssl.keystore.location = null
        ssl.keystore.password = null
        ssl.keystore.type = JKS
        ssl.principal.mapping.rules = DEFAULT
        ssl.protocol = TLSv1.2
        ssl.provider = null
        ssl.secure.random.implementation = null
        ssl.trustmanager.algorithm = PKIX
        ssl.truststore.certificates = null
        ssl.truststore.location = null
        ssl.truststore.password = null
        ssl.truststore.type = JKS
        transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000
        transaction.max.timeout.ms = 900000
        transaction.remove.expired.transaction.cleanup.interval.ms = 3600000
        transaction.state.log.load.buffer.size = 5242880
        transaction.state.log.min.isr = 1
        transaction.state.log.num.partitions = 50
        transaction.state.log.replication.factor = 1
        transaction.state.log.segment.bytes = 104857600
        transactional.id.expiration.ms = 604800000
        unclean.leader.election.enable = false
        zookeeper.clientCnxnSocket = null
        zookeeper.connect = 192.168.19.134:7181,192.168.19.134:7182,192.168.19.134:7183
        zookeeper.connection.timeout.ms = 18000
        zookeeper.max.in.flight.requests = 10
        zookeeper.session.timeout.ms = 18000
        zookeeper.set.acl = false
        zookeeper.ssl.cipher.suites = null
        zookeeper.ssl.client.enable = false
        zookeeper.ssl.crl.enable = false
        zookeeper.ssl.enabled.protocols = null
        zookeeper.ssl.endpoint.identification.algorithm = HTTPS
        zookeeper.ssl.keystore.location = null
        zookeeper.ssl.keystore.password = null
        zookeeper.ssl.keystore.type = null
        zookeeper.ssl.ocsp.enable = false
        zookeeper.ssl.protocol = TLSv1.2
        zookeeper.ssl.truststore.location = null
        zookeeper.ssl.truststore.password = null
        zookeeper.ssl.truststore.type = null
        zookeeper.sync.time.ms = 2000
 (kafka.server.KafkaConfig)
[2021-11-08 14:22:18,742] INFO KafkaConfig values: 
        advertised.host.name = null
        advertised.listeners = SASL_PLAINTEXT://192.168.19.134:7281
        advertised.port = null
        alter.config.policy.class.name = null
        alter.log.dirs.replication.quota.window.num = 11
        alter.log.dirs.replication.quota.window.size.seconds = 1
        authorizer.class.name = 
        auto.create.topics.enable = true
        auto.leader.rebalance.enable = true
        background.threads = 10
        broker.heartbeat.interval.ms = 2000
        broker.id = 1
        broker.id.generation.enable = true
        broker.rack = null
        broker.session.timeout.ms = 9000
        client.quota.callback.class = null
        compression.type = producer
        connection.failed.authentication.delay.ms = 100
        connections.max.idle.ms = 600000
        connections.max.reauth.ms = 0
        control.plane.listener.name = null
        controlled.shutdown.enable = true
        controlled.shutdown.max.retries = 3
        controlled.shutdown.retry.backoff.ms = 5000
        controller.listener.names = null
        controller.quorum.append.linger.ms = 25
        controller.quorum.election.backoff.max.ms = 1000
        controller.quorum.election.timeout.ms = 1000
        controller.quorum.fetch.timeout.ms = 2000
        controller.quorum.request.timeout.ms = 2000
        controller.quorum.retry.backoff.ms = 20
        controller.quorum.voters = []
        controller.quota.window.num = 11
        controller.quota.window.size.seconds = 1
        controller.socket.timeout.ms = 30000
        create.topic.policy.class.name = null
        default.replication.factor = 3
        delegation.token.expiry.check.interval.ms = 3600000
        delegation.token.expiry.time.ms = 86400000
        delegation.token.master.key = null
        delegation.token.max.lifetime.ms = 604800000
        delegation.token.secret.key = null
        delete.records.purgatory.purge.interval.requests = 1
        delete.topic.enable = true
        fetch.max.bytes = 57671680
        fetch.purgatory.purge.interval.requests = 1000
        group.initial.rebalance.delay.ms = 0
        group.max.session.timeout.ms = 1800000
        group.max.size = 2147483647
        group.min.session.timeout.ms = 6000
        host.name = 
        initial.broker.registration.timeout.ms = 60000
        inter.broker.listener.name = null
        inter.broker.protocol.version = 2.8-IV1
        kafka.metrics.polling.interval.secs = 10
        kafka.metrics.reporters = []
        leader.imbalance.check.interval.seconds = 300
        leader.imbalance.per.broker.percentage = 10
        listener.security.protocol.map = PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL
        listeners = SASL_PLAINTEXT://192.168.19.134:7281
        log.cleaner.backoff.ms = 15000
        log.cleaner.dedupe.buffer.size = 134217728
        log.cleaner.delete.retention.ms = 86400000
        log.cleaner.enable = true
        log.cleaner.io.buffer.load.factor = 0.9
        log.cleaner.io.buffer.size = 524288
        log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308
        log.cleaner.max.compaction.lag.ms = 9223372036854775807
        log.cleaner.min.cleanable.ratio = 0.5
        log.cleaner.min.compaction.lag.ms = 0
        log.cleaner.threads = 1
        log.cleanup.policy = [delete]
        log.dir = /tmp/kafka-logs
        log.dirs = /data/kafka/logs/kafka-2.8.0/7281
        log.flush.interval.messages = 9223372036854775807
        log.flush.interval.ms = null
        log.flush.offset.checkpoint.interval.ms = 60000
        log.flush.scheduler.interval.ms = 9223372036854775807
        log.flush.start.offset.checkpoint.interval.ms = 60000
        log.index.interval.bytes = 4096
        log.index.size.max.bytes = 10485760
        log.message.downconversion.enable = true
        log.message.format.version = 2.8-IV1
        log.message.timestamp.difference.max.ms = 9223372036854775807
        log.message.timestamp.type = CreateTime
        log.preallocate = false
        log.retention.bytes = -1
        log.retention.check.interval.ms = 300000
        log.retention.hours = 48
        log.retention.minutes = null
        log.retention.ms = null
        log.roll.hours = 168
        log.roll.jitter.hours = 0
        log.roll.jitter.ms = null
        log.roll.ms = null
        log.segment.bytes = 1073741824
        log.segment.delete.delay.ms = 60000
        max.connection.creation.rate = 2147483647
        max.connections = 2147483647
        max.connections.per.ip = 2147483647
        max.connections.per.ip.overrides = 
        max.incremental.fetch.session.cache.slots = 1000
        message.max.bytes = 1048588
        metadata.log.dir = null
        metric.reporters = []
        metrics.num.samples = 2
        metrics.recording.level = INFO
        metrics.sample.window.ms = 30000
        min.insync.replicas = 1
        node.id = -1
        num.io.threads = 8
        num.network.threads = 3
        num.partitions = 1
        num.recovery.threads.per.data.dir = 1
        num.replica.alter.log.dirs.threads = null
        num.replica.fetchers = 1
        offset.metadata.max.bytes = 4096
        offsets.commit.required.acks = -1
        offsets.commit.timeout.ms = 5000
        offsets.load.buffer.size = 5242880
        offsets.retention.check.interval.ms = 600000
        offsets.retention.minutes = 10080
        offsets.topic.compression.codec = 0
        offsets.topic.num.partitions = 50
        offsets.topic.replication.factor = 1
        offsets.topic.segment.bytes = 104857600
        password.encoder.cipher.algorithm = AES/CBC/PKCS5Padding
        password.encoder.iterations = 4096
        password.encoder.key.length = 128
        password.encoder.keyfactory.algorithm = null
        password.encoder.old.secret = null
        password.encoder.secret = null
        port = 9092
        principal.builder.class = null
        process.roles = []
        producer.purgatory.purge.interval.requests = 1000
        queued.max.request.bytes = -1
        queued.max.requests = 500
        quota.consumer.default = 9223372036854775807
        quota.producer.default = 9223372036854775807
        quota.window.num = 11
        quota.window.size.seconds = 1
        replica.fetch.backoff.ms = 1000
        replica.fetch.max.bytes = 1048576
        replica.fetch.min.bytes = 1
        replica.fetch.response.max.bytes = 10485760
        replica.fetch.wait.max.ms = 500
        replica.high.watermark.checkpoint.interval.ms = 5000
        replica.lag.time.max.ms = 30000
        replica.selector.class = null
        replica.socket.receive.buffer.bytes = 65536
        replica.socket.timeout.ms = 30000
        replication.quota.window.num = 11
        replication.quota.window.size.seconds = 1
        request.timeout.ms = 30000
        reserved.broker.max.id = 1000
        sasl.client.callback.handler.class = null
        sasl.enabled.mechanisms = [PLAIN]
        sasl.jaas.config = null
        sasl.kerberos.kinit.cmd = /usr/bin/kinit
        sasl.kerberos.min.time.before.relogin = 60000
        sasl.kerberos.principal.to.local.rules = [DEFAULT]
        sasl.kerberos.service.name = null
        sasl.kerberos.ticket.renew.jitter = 0.05
        sasl.kerberos.ticket.renew.window.factor = 0.8
        sasl.login.callback.handler.class = null
        sasl.login.class = null
        sasl.login.refresh.buffer.seconds = 300
        sasl.login.refresh.min.period.seconds = 60
        sasl.login.refresh.window.factor = 0.8
        sasl.login.refresh.window.jitter = 0.05
        sasl.mechanism.controller.protocol = GSSAPI
        sasl.mechanism.inter.broker.protocol = PLAIN
        sasl.server.callback.handler.class = null
        security.inter.broker.protocol = SASL_PLAINTEXT
        security.providers = null
        socket.connection.setup.timeout.max.ms = 30000
        socket.connection.setup.timeout.ms = 10000
        socket.receive.buffer.bytes = 102400
        socket.request.max.bytes = 104857600
        socket.send.buffer.bytes = 102400
        ssl.cipher.suites = []
        ssl.client.auth = none
        ssl.enabled.protocols = [TLSv1.2]
        ssl.endpoint.identification.algorithm = https
        ssl.engine.factory.class = null
        ssl.key.password = null
        ssl.keymanager.algorithm = SunX509
        ssl.keystore.certificate.chain = null
        ssl.keystore.key = null
        ssl.keystore.location = null
        ssl.keystore.password = null
        ssl.keystore.type = JKS
        ssl.principal.mapping.rules = DEFAULT
        ssl.protocol = TLSv1.2
        ssl.provider = null
        ssl.secure.random.implementation = null
        ssl.trustmanager.algorithm = PKIX
        ssl.truststore.certificates = null
        ssl.truststore.location = null
        ssl.truststore.password = null
        ssl.truststore.type = JKS
        transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000
        transaction.max.timeout.ms = 900000
        transaction.remove.expired.transaction.cleanup.interval.ms = 3600000
        transaction.state.log.load.buffer.size = 5242880
        transaction.state.log.min.isr = 1
        transaction.state.log.num.partitions = 50
        transaction.state.log.replication.factor = 1
        transaction.state.log.segment.bytes = 104857600
        transactional.id.expiration.ms = 604800000
        unclean.leader.election.enable = false
        zookeeper.clientCnxnSocket = null
        zookeeper.connect = 192.168.19.134:7181,192.168.19.134:7182,192.168.19.134:7183
        zookeeper.connection.timeout.ms = 18000
        zookeeper.max.in.flight.requests = 10
        zookeeper.session.timeout.ms = 18000
        zookeeper.set.acl = false
        zookeeper.ssl.cipher.suites = null
        zookeeper.ssl.client.enable = false
        zookeeper.ssl.crl.enable = false
        zookeeper.ssl.enabled.protocols = null
        zookeeper.ssl.endpoint.identification.algorithm = HTTPS
        zookeeper.ssl.keystore.location = null
        zookeeper.ssl.keystore.password = null
        zookeeper.ssl.keystore.type = null
        zookeeper.ssl.ocsp.enable = false
        zookeeper.ssl.protocol = TLSv1.2
        zookeeper.ssl.truststore.location = null
        zookeeper.ssl.truststore.password = null
        zookeeper.ssl.truststore.type = null
        zookeeper.sync.time.ms = 2000
 (kafka.server.KafkaConfig)
[2021-11-08 14:22:18,777] INFO [ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-08 14:22:18,778] INFO [ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-08 14:22:18,779] INFO [ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-08 14:22:18,787] INFO [ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2021-11-08 14:22:18,811] INFO Loading logs from log dirs ArraySeq(/data/kafka/logs/kafka-2.8.0/7281) (kafka.log.LogManager)
[2021-11-08 14:22:18,815] INFO Skipping recovery for all logs in /data/kafka/logs/kafka-2.8.0/7281 since clean shutdown file was found (kafka.log.LogManager)
[2021-11-08 14:22:18,823] INFO Loaded 0 logs in 12ms. (kafka.log.LogManager)
[2021-11-08 14:22:18,824] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager)
[2021-11-08 14:22:18,828] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager)
[2021-11-08 14:22:19,188] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas)
[2021-11-08 14:22:19,192] INFO Awaiting socket connections on 192.168.19.134:7281. (kafka.network.Acceptor)
[2021-11-08 14:22:19,214] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin)
[2021-11-08 14:22:19,228] INFO [SocketServer listenerType=ZK_BROKER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(SASL_PLAINTEXT) (kafka.network.SocketServer)
[2021-11-08 14:22:19,254] INFO [broker-1-to-controller-send-thread]: Starting (kafka.server.BrokerToControllerRequestThread)
[2021-11-08 14:22:19,271] INFO [ExpirationReaper-1-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-08 14:22:19,271] INFO [ExpirationReaper-1-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-08 14:22:19,271] INFO [ExpirationReaper-1-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-08 14:22:19,275] INFO [ExpirationReaper-1-ElectLeader]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-08 14:22:19,286] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler)
[2021-11-08 14:22:19,328] INFO Creating /brokers/ids/1 (is it secure? false) (kafka.zk.KafkaZkClient)
[2021-11-08 14:22:19,377] INFO Stat of the created znode at /brokers/ids/1 is: 4294967337,4294967337,1636352539360,1636352539360,1,0,0,144120658184044544,213,0,4294967337
 (kafka.zk.KafkaZkClient)
[2021-11-08 14:22:19,378] INFO Registered broker 1 at path /brokers/ids/1 with addresses: SASL_PLAINTEXT://192.168.19.134:7281, czxid (broker epoch): 4294967337 (kafka.zk.KafkaZkClient)
[2021-11-08 14:22:19,435] INFO [ExpirationReaper-1-topic]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-08 14:22:19,436] INFO [ExpirationReaper-1-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-08 14:22:19,440] INFO [ExpirationReaper-1-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-08 14:22:19,462] INFO [GroupCoordinator 1]: Starting up. (kafka.coordinator.group.GroupCoordinator)
[2021-11-08 14:22:19,463] INFO Successfully created /controller_epoch with initial epoch 0 (kafka.zk.KafkaZkClient)
[2021-11-08 14:22:19,473] INFO [GroupCoordinator 1]: Startup complete. (kafka.coordinator.group.GroupCoordinator)
[2021-11-08 14:22:19,505] INFO Feature ZK node created at path: /feature (kafka.server.FinalizedFeatureChangeListener)
[2021-11-08 14:22:19,524] INFO Updated cache from existing  to latest FinalizedFeaturesAndEpoch(features=Features{}, epoch=0). (kafka.server.FinalizedFeatureCache)
[2021-11-08 14:22:19,543] INFO [ProducerId Manager 1]: Acquired new producerId block (brokerId:1,blockStartProducerId:0,blockEndProducerId:999) by writing to Zk with path version 1 (kafka.coordinator.transaction.ProducerIdManager)
[2021-11-08 14:22:19,543] INFO [TransactionCoordinator id=1] Starting up. (kafka.coordinator.transaction.TransactionCoordinator)
[2021-11-08 14:22:19,549] INFO [TransactionCoordinator id=1] Startup complete. (kafka.coordinator.transaction.TransactionCoordinator)
[2021-11-08 14:22:19,556] INFO [Transaction Marker Channel Manager 1]: Starting (kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2021-11-08 14:22:19,582] INFO [ExpirationReaper-1-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2021-11-08 14:22:19,615] INFO [/config/changes-event-process-thread]: Starting (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread)
[2021-11-08 14:22:19,625] INFO [SocketServer listenerType=ZK_BROKER, nodeId=1] Starting socket server acceptors and processors (kafka.network.SocketServer)
[2021-11-08 14:22:19,658] INFO [SocketServer listenerType=ZK_BROKER, nodeId=1] Started data-plane acceptor and processor(s) for endpoint : ListenerName(SASL_PLAINTEXT) (kafka.network.SocketServer)
[2021-11-08 14:22:19,659] INFO [SocketServer listenerType=ZK_BROKER, nodeId=1] Started socket server acceptors and processors (kafka.network.SocketServer)
[2021-11-08 14:22:19,666] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser)
[2021-11-08 14:22:19,666] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser)
[2021-11-08 14:22:19,666] INFO Kafka startTimeMs: 1636352539659 (org.apache.kafka.common.utils.AppInfoParser)
[2021-11-08 14:22:19,667] INFO [KafkaServer id=1] started (kafka.server.KafkaServer)
[2021-11-08 14:22:19,772] INFO [broker-1-to-controller-send-thread]: Recorded new controller, from now on will use broker 192.168.19.134:7281 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread)
----【节点已经正常启动】
----【剩下的也都可以正常启动了，因日志比较多就不做展示了，请见谅~】

以上就是伪集群kafka环境部署，仅供参考，真正的集群和此配置基本一致

如果有哪些地方配置不对还请大佬指出来，非常感谢