我storm应用,像开启了kerberos的kafka写入数据,现在报错,具体报错信息如下图:
我的生产者代码:
Strom用的是Bolt组件来发送消息,但是一直连接不上kafka,kafka是别人提供的。第三方提供的人说命令能运行成功,现在不知道什么问题,请大佬帮忙解决看一看。
建议这么做:
1. 先测试下连接无kerberos的kafka,验证下strom连kafka是否正常
2. 在storm集群服务器上面(非nimbus),用命令行连接开启kerberos的kafka,验证是否存在网络或配置问题
我Storm集群服务器没安装KAFKA,这个测试命令是什么呢
您好,我是问答小助手,你的问题已经有小伙伴为您解答了问题,您看下是否解决了您的问题。
如果有您比较满意的答案 / 帮您提供解决思路的答案,可以点击【采纳】按钮,给回答的小伙伴一些鼓励哦~~