Развертывание топологии на сервере Storm Ошибка: NoNode для / brokers / themes / blockdata / partitions - PullRequest
Новая
       7

Развертывание топологии на сервере Storm Ошибка: NoNode для / brokers / themes / blockdata / partitions

0 голосов
/ 28 мая 2018

Я пытаюсь развернуть топологию шторма / потока на удаленном сервере.Топология успешно развернута, но в пользовательском интерфейсе шторма серверов она показывает ошибку задержки носика:

Невозможно получить лаги смещения для kafka.Причина: org.apache.zookeeper.KeeperException $ NoNodeException: KeeperErrorCode = NoNode для / brokers / themes / blockdata / partitions at org.apache.zookeeper.keeperExceptiom.create ...

Хотя я проверялв моем зоопарке, используя следующее: 

ls /brokers/topics/blockdata/partitions, it exists.

Вот моя конфигурация носика: 

  - id: "zkHosts"
    className: "org.apache.storm.kafka.ZkHosts"
    constructorArgs:
      - "172.25.33.191:2181"

  - id: "startingOffsetTime"
    className: "kafka.api.OffsetRequest"
    factory: "LatestTime"



  - id: "spoutConfig"
    className: "org.apache.storm.kafka.SpoutConfig"
    constructorArgs:
      - ref: "zkHosts"
      - "blockdata"
      - "/brokers/topics"
      - "myId"
    properties:
      - name: "ignoreZkOffsets"
        value: true
      - name: "scheme"
        ref: "stringMultiScheme"
      - name: "startOffsetTime"
        ref: "startingOffsetTime"

ПРИМЕЧАНИЕ. Эта топология работает нормально в локальном режиме.

Пожалуйста, смотрите скриншоты ниже:

Снимок экрана с ошибкой

Ответы [ 2 ]

0 голосов
/ 28 июля 2018

Вы не можете использовать collector.ack (tuple);в вашем болте. Это приводит к тому, что кортеж повторения отправки носика не записывается в zookeeper.

0 голосов
/ 29 мая 2018

Это происходит из части пользовательского интерфейса Storm, которая должна показывать вам, как далеко ваш носик находится за смещением конца журнала.Если вас интересует код, приведенный здесь https://github.com/apache/storm/blob/v1.2.1/external/storm-kafka-monitor/src/main/java/org/apache/storm/kafka/monitor/KafkaOffsetLagUtil.java

Пожалуйста, попробуйте немного поработать с топологией, затем попробуйте снова открыть интерфейс Storm и посмотреть, не возникает ли ошибка.Возможно, вы случайно открыли Storm UI до того, как носик Кафки успел написать Zookeeper.

...