Question

Java使用kafka发送消息没有生效

看了网上很多示例，都是按示例配的奈何就是生效不了，并且之前已经在一个项目中编写过向kafka发送消息的代码，是没有问题的，现在将代码复制到这另一个项目以后就没法生效了，求解。





Answer 1

一般消息发不出去很大可能都是配置或环境的问题
1、排查环境是否有问题，zookeeper节点是否存活，kafka节点是否存活，通过命令行的方式能否发出去消息（使用kafka-console-producer.sh）,如果通过命令行都发不出去那就是集群的问题了。
2、网络问题，调用机器和集群之间网络是否通畅
3、调用时配置的host、port和集群中配置的是否一致，是否需要使用主机名而不是ip
4、客户端api版本是否和服务端差别太大导致不兼容
5、防火墙问题，关闭集群的防火墙实时
诸如此类，可能性太多就不一 一列举了。
你这既然有打印堆栈，如果报错肯定有异常信息的，可能卡住的时间比较长，耐心等待吧，祝你早日解决bug。

追问

kafka的环境和配置是在另一个系统里面，那我这里也还需要配置zookeeper节点吗？

追答

不需要。如果有别人也在用这个集群你可以问问他们是怎么连接的。

追问

就是感觉很奇怪，我想不通，我在A项目也使用了这段代码，发送数据完全没有问题，可是到了B项目我使用以后就死活都发不了，kafka那边的环境和配置应该是没问题的，如果有问题的话那A项目肯定也是发不过去的