(8条消息) kafka消费者kafka

问题
采用内置的zookeeper，发送端发送数据，接收端能够接收数据
但是采用外置的zookeeper，发送端发送数据，接收端一直接收不到数据
解决：
先判断主题是否一致，如果一致就在关闭kafka
./kafka-server-stop.sh ../config/server.properties
修改一下配置，确保这些配置已加上，不要用localhost，在listeners的ip地址和端口号要和消费者，生产者的的地址端口号一直
vim ../config/server.propertiesst3

最后把log.dirs后面的文件删除或者重新换个地址
rm -rf /tmp/kafka

重新在前台启动kafka，注意查看打印在桌面的日志，有无报错信息
./kafka-server-start.sh ../config/server.properties
如果没有报错信息，启动正常，那么就可以在后台启动了
./kafka-server-start.sh -daemon ../config/server.properties
创建生产者
./kafka-console-producer.sh --broker-list 172.16.193.175:9092 --topic test3
创建消费者
./kafka-console-consumer.sh --bootstrap-server 172.16.193.175:9092 --topic test3 --from-beginning