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

发布网友 发布时间:2022-04-21 23:09

我来回答

1个回答

热心网友 时间:2023-07-09 09:52

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

声明声明:本网页内容为用户发布,旨在传播知识,不代表本网认同其观点,若有侵权等问题请及时与本网联系,我们将在第一时间删除处理。E-MAIL:11247931@qq.com