这家伙太懒,什么都没留下
config/server.properties中
config/server.properties
listeners=PLAINTEXT://你的ip:9092
配置了吗
单节点的
kafka集群中所有的节点都telnet下试试,必须都通。
你的设计是错的,kafka poll是长轮训,也是长链接,批次获取消息。不要关闭,由它来统一给你派发消息。