kafka部署的问题

1. 连接zookeeper超时

kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING

这个问题的是由于kafka启动的时候连接zookeeper比较慢, 把超时时间设置大一点就可以了,默认是6000ms

server.properties中增加

zookeeper.connection.timeout.ms=6000000

2. 发送消息时报一下错误

java.lang.IllegalStateException: No entry found for connection 0

server.properties中增加

advertised.listeners=PLAINTEXT://172.28.21.243:9092

ip地址为发送消息端连接kafka的ip地址