zoukankan      html  css  js  c++  java
  • kafka连接storm问题

    遇到缺少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

  • 相关阅读:
    预编译命令 #if DEBUG
    conda常用命令
    tensorflow 安装指南
    LocNET和池化理解
    同时安装cuda8和cuda9
    np.transpose
    python中List的slice用法
    书单
    训练工程
    linux 查看进程
  • 原文地址:https://www.cnblogs.com/shiwaitaoyuan/p/11967665.html
Copyright © 2011-2022 走看看