首页 > 其他 > 详细

kafka连接storm问题

时间:2019-12-01 21:29:54      阅读:112      评论:0      收藏:0      [点我收藏+]

遇到缺少jar包的报错,参考https://www.jianshu.com/p/70c3a7f56386

参考上面的链接把jar包都放到storm/lib目录下后,使用localCluster的方法提交的topology成功运行

但是使用StormSubmitter提交的topology接收不到kafka发送的消息

web报错如下:拒绝连接

启动后报错类似  kill: 向 5432 发送信号失败: 没有那个进程

原因:只有主机器上的storm的lib下上传了需要的jar包,从机器上的storm没有上传jar包

 

版本说明:

storm的版本:apache-storm-0.9.3

zookeeper版本:zookeeper-3.4.5

scala版本:scala-2.10.5

kafka版本:kafka_2.10-0.10.2.2

需要上传到storm lib目录下的jar包:

storm-kafka-0.9.3.jar

scala-library-2.10.5.jar

kafka_2.10-0.8.2.1.jar

metrics-core-2.2.0.jar

guava-11.0.2.jar

curator-client-2.6.0.jar

curator-framework-2.6.0.jar

zookeeper-3.4.5.jar

kafka连接storm问题

原文:https://www.cnblogs.com/shiwaitaoyuan/p/11967665.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!