我正在使用ApacheStorm1.1.2、ApacheKafka0.10、zookeeper和DockerCompose编写一个DockerJava9Spring应用程序。
我的拓扑结构完全是在我的停靠服务内部的本地集群上工作的，但是现在我要把它移到生产集群上，有一个问题。
我创建一个提交拓扑到storm集群的服务似乎工作得很好，代码在一个postconstruct中看起来主要是这样的

KafkaSpoutConfig<String,String> spoutConf = 
KafkaSpoutConfig.builder("kafka:9092", "topic")
  .setProp(ConsumerConfig.GROUP_ID_CONFIG, "my-group-id")
  .setProp(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, MyDeserializer.class)
.build();

TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("kafkaSpoutId", new KafkaSpout<String,String>(spoutConf));
builder.setBolt("boltId", new MyBolt()).shuffleGrouping("kafkaSpoutId");

Config conf = new Config();
conf.setNumWorkers(2);
conf.put(Config.STORM_ZOOKEEPER_SERVERS, List.of("zookeeper"));
conf.put(Config.STORM_ZOOKEEPER_PORT, 2181);

conf.put(Config.NIMBUS_SEEDS, List.of("nimbus"));
conf.put(Config.NIMBUS_THRIFT_PORT, 6627);

System.setProperty("storm.jar","/opt/app.jar");
StormSubmitter.submitTopology("topology-id", conf, builder.createTopology());

我的docker文件是这样的。

version: "2.1"

services:
  my-service:
  image: my-service
  mem_limit: 4G
  memswap_limit: 4G
  networks:
    - default
  environment:
    - SPRING_PROFILES_ACTIVE=local

nimbus:
  image: storm:1.1.2
  container_name: nimbus
  command: >
    storm nimbus
      -c storm.zookeeper.servers="[\"zookeeper\"]"
      -c nimbus.seeds="[\"nimbus\"]"
  networks:
    - default
  ports:
    - 6627:6627

supervisor:
  image: storm:1.1.2
  container_name: supervisor
  command: >
    storm supervisor
      -c storm.zookeeper.servers="[\"zookeeper\"]"
      -c nimbus.seeds="[\"nimbus\"]"
  networks:
    - default
  depends_on:
    - nimbus
  links:
    - nimbus
  restart: always
  ports:
    - 6700
    - 6701
    - 6702
    - 6703

ui:
  image: storm:1.1.2
  command: storm ui -c nimbus.seeds="[\"nimbus\"]"
  networks: 
    - default
  ports:
    - 8081:8080

networks:
  default:
    external:
      name: myNetwork

所有的集装箱都装上了。在ui中，我可以看到post构造中创建的拓扑，但是没有处理kafka消息，应该使用本地kafka生产者生成聚合的bolt没有发布。
在主管容器中 /logs/worker-artifact/topology-id****/6700/worker.log 我可以看到重复出现了两个例外。
第一个（我认为更重要的是）是 ClassNotFoundException: org.apache.storm.kafka.spout.KafkaSpout 第二个例外是 org.apache.storm.shade.org.jboss.netty.channel.ChannelException: Failed to bind to: 0.0.0.0/0.0.0.0:6700 更新
不幸的是，我不能张贴我的整个pom，但这里是我的风暴依赖

<dependency>
        <groupId>org.apache.storm</groupId>
        <artifactId>storm-core</artifactId>
        <version>${storm.version}</version>
    </dependency>

    <dependency>
        <groupId>org.apache.storm</groupId>
        <artifactId>storm-kafka-client</artifactId>
        <version>${storm.version}</version>
    </dependency>

    <dependency>
        <groupId>javax.servlet</groupId>
        <artifactId>javax.servlet-api</artifactId>
    </dependency>

这里有一个我的springbootmaven插件。我认为添加配置以使复制到容器中的jar不可执行就可以了。当我检查容器中的jar时，它看起来包含了jar中的依赖项行，但也包含了大量乱七八糟的字符

<build>
    <plugins>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
            <configuration>
              <executable>false</executable>
            </configuration>
        </plugin>

        <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-resources-plugin</artifactId>
        </plugin>
    </plugins>
</build>

这是我的大部分文件

FROM ${docker.repository}/openjdk:9.0.1

EXPOSE 80 1099

WORKDIR /opt

ENTRYPOINT ["java", \
    "-Dinfo.serviceName=${project.artifactId}", \
    "-Dinfo.serviceVersion=${project.version}"]

CMD ["-jar", "app.jar"]

LABEL VERSION="${project.version}" DESCRIPTION="${project.description}"

COPY ${project.build.finalName}-exec.jar /opt/app.jar