1.问题

zookeeper集群、kafka集群启动成功，但是在使用kafka-console-producer.sh 和 kafka-console-consumer.sh 进行消息的发送和消费测试时报错。

2.版本

zookeeper版本： 3.5.8
kafka版本: 2.12-2.5.0
linux版本： Centos7

3.配置

3.1 IP

            阿里云          腾讯云
公网IP   47.98.221.77    81.68.194.208
内网IP   172.16.26.150   172.17.0.10

3.2 hosts文件

阿里云

# zookeeper 集群
81.68.194.208 xzh
127.0.0.1  pd
# kafka 集群
172.16.26.150  kafka-aliyun
172.17.0.10    kafka-tx

腾讯云

# zookeeper 集群
47.98.221.77 pd
127.0.0.1    xzh
# kafka 集群
172.16.26.150  kafka-aliyun
172.17.0.10    kafka-tx

3.3 zk zoo.cfg

# 阿里云
server.0=pd:2888:3888    # 阿里云里 myid = 0
server.1=xzh:2888:3888   # 腾讯云里 myid = 1
quorumListenOnAllIPs=true

# 腾讯云
server.0=pd:2888:3888
server.1=xzh:2888:3888
quorumListenOnAllIPs=true

3.4 kafka server.properties

# 阿里云
broker.id=2
listeners=PLAINTEXT://kafka-aliyun:9092
advertised.listeners=PLAINTEXT://47.98.221.77:9092
zookeeper.connect=xzh:2181,pd:2181

# 腾讯云
broker.id=3
listeners=PLAINTEXT://kafka-tx:9092
advertised.listeners=PLAINTEXT://81.68.194.208:9092
zookeeper.connect=xzh:2181,pd:2181

3.5 发送消费消息代码

# 创建topic
kafka-topics.sh --bootstrap-server 172.16.26.150:9092 --create --topic transaction --partitions 1 --replication-factor 1 

# 创建消费者
kafka-console-consumer.sh --bootstrap-server 172.16.26.150:9092 --topic transaction

# 创建生产者
kafka-console-producer.sh --broker-list 172.16.26.150:9092 --topic transaction

4.错误