strom应用向开启kerberos的kafka写入数据

我storm应用,像开启了kerberos的kafka写入数据,现在报错,具体报错信息如下图:

我的生产者代码:

 

Strom用的是Bolt组件来发送消息,但是一直连接不上kafka,kafka是别人提供的。第三方提供的人说命令能运行成功,现在不知道什么问题,请大佬帮忙解决看一看。

建议这么做:

1. 先测试下连接无kerberos的kafka,验证下strom连kafka是否正常

2. 在storm集群服务器上面(非nimbus),用命令行连接开启kerberos的kafka,验证是否存在网络或配置问题

我Storm集群服务器没安装KAFKA,这个测试命令是什么呢

  1. 我Storm集群服务器没安装KAFKA,这个测试命令是什么呢
  2. 网络是正常的,测试过一遍。能接受到另外服务器kafka的消息,就是不能往新服务器插入kafka数据

您好,我是问答小助手,你的问题已经有小伙伴为您解答了问题,您看下是否解决了您的问题。

如果有您比较满意的答案 / 帮您提供解决思路的答案,可以点击【采纳】按钮,给回答的小伙伴一些鼓励哦~~