Apache Проблемы развертывания топологии шторма - PullRequest
Новая
       6

Apache Проблемы развертывания топологии шторма

0 голосов
/ 08 января 2020

Я создал локальный кластер на моей машине, чтобы попробовать развертывание топологии Storm, но у меня странная проблема. Поэтому, когда я выполняю топологию в локальном режиме, все работает нормально, но когда я выполняю в удаленном режиме, она, кажется, не работает, как вы можете видеть на скриншоте ниже: Storm topology overwiew

На данный момент я не могу понять, в чем проблема, я также проверил, работает ли производитель Kafka, и это прекрасно работает, потому что в этой топологии используется носик Kafka. Большое спасибо за вашу помощь.

Это storm.yml 

 storm.log4j2.conf.dir: "log4j2"

 storm.zookeeper.servers:
     - "127.0.0.1"

 nimbus.seeds: ["127.0.0.1"]

 supervisor.slots.ports:
    - 6700

Это файл stack.yml 

version: '3'

services:
    nimbus:
        image: storm:2.1.0
        container_name: nimbus
        command: storm nimbus  -c storm.zookeeper.servers="[\"zookeeper\"]"  -c nimbus.seeds="[\"nimbus\"]"
        depends_on:
            - zookeeper
        links:
            - zookeeper
        restart: always
        ports:
            - "6627:6627"
            - "8000:8000"
        volumes:
            - ./TopologyJar:/TopologyJar

    zookeeper:
        image: zookeeper
        container_name: zookeeper
        restart: always
        ports:
             - "2181:2181"

#    storm-cli:
#        image: storm:2.1.0
#        container_name: storm-cli
#        depends_on:
#            - zookeeper
#            - nimbus
#        links:
#            - zookeeper
#            - nimbus
#
#        #The following two comands
#        #are used for showing an I/O terminal aka Shell
##        stdin_open: true
##        tty: true

    storm-ui: 
        image: storm:2.1.0
        container_name: storm-ui
        command: storm ui  -c nimbus.seeds="[\"nimbus\"]"  -c storm.zookeeper.servers="[\"zookeeper\"]"
        depends_on: 
            - nimbus
            - zookeeper
        links: 
            - nimbus
            - zookeeper
        restart: always
        ports:
            - "8080:8080"

    supervisor:
        image: storm:2.1.0
        command: storm supervisor -c nimbus.seeds="[\"nimbus\"]"  -c storm.zookeeper.servers="[\"zookeeper\"]"
        container_name: supervisor
        depends_on:
            - nimbus
            - zookeeper
            - redis
        links:
            - nimbus
            - zookeeper
            - redis
        restart: always

    redis:
        image: redis
        container_name: redis
        restart: always
        ports:
            - "6379:6379"

#web iu for manage redis
    redis-commander:
        container_name: redis-commander
        hostname: redis-commander
        image: rediscommander/redis-commander:latest
        restart: always
        environment:
        - REDIS_HOSTS=local:redis:6379
        ports:
            - "8081:8081"
        depends_on:
            - redis
...