阿里云+腾讯云下kafka集群,内网ip、外网ip配置不清,导致在服务器kafka客户端使用kafka-console-producer.sh 报错?

say goodbye 发表于: 2021-04-02   最后更新时间: 2021-04-07 23:54:13   167 游览
0

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.错误



发表于 20天前

  • 问题解决了,还是要感谢你百忙之中还帮忙看一下, 主要是 listeners=PLAINTEXT://0.0.0.0:9092改成这样就好了,麻烦了

    看了看配置,看上去没问题,补充几个问题。
    1、查看kafka的启动日志,看看是否成功。
    2、netstat -altp 可以查看网络连接是否建立成功。

  • 找不到想要的答案?

    我要提问
    相关