Брокер начальной загрузки отключен => KeeperErrorCode = NoNode для / brokers / topcis / xxxx / partitions / 2 / state + Ключ не найден

Question

Я пытаюсь запустить kafka-console-consume.sh для темы XXX

sh kafka-console-consumer.sh --bootstrap-server abcd:9092, bcde:9092, cdef:9092 --topic XXX

появляется ошибка ниже:

WARN клиентов. NetworkClient: Botstrapbroker abcd: 9092 отключен

WARN клиентов. NetworkClient: Botstrapbroker bcde: 9092 отключен

WARN клиентов. NetworkClient: Botstrapbroker cdef: 9092 отключен

Когда я регистрируюсь в журнале брокера, нет ошибки, кроме приведенного ниже предупреждения:

WARN nl.techop.kafka.dao.zookeeper.KafkaZkClient: KeeperErrorCode = NoNode для / brokers / themes / XXX / partitions / 2 / state WARN com.yammer.metrics.reporting.MetricsServlet: ошибка при оценке датчика java.util.NoSuchElementException: ключ не найден: [XXX, 0]

Что я пробовал:

Я успешно создал тему testing123, указанную ниже:

    sh kafka-topics.sh --create --zookeeper defg:2181, dfde:2181, cdef:2181
--replication-factor 3 --partitions 3 --topic testing123

однако, когда я пытаюсь использовать kafka-console-producer.sh, происходит та же ошибка:

sh kafka-console-producer.sh --broker-list abcd:9092, bcde:9092, cdef:9092

WARN клиентов. NetworkClient: брокер Botstrap abcd: 9092 отключен
WARN клиентов. NetworkClient: Botstrap брокер bcde: 9092 отключен
Клиенты WARN.NetworkClient: брокер Botstrap cdef: 9092 отключен

Answer 1

Спасибо всем.

Кластер с поддержкой Kerberos.

Я решил проблему, добавив нижеприведенное ниже в свой файл свойств consumer.config:

• group.id = flume
  security.protocol = SASL_PLAINTEXT
  sasl.kerberos.service.name = kafka sasl.mechanism = GSSAPI
  ssl.client.auth = нет

и запустить ниже:

sh kafka-console-consumer.sh --bootstrap-server abcd:9092, bcde:9092, cdef:9092 --topic XXX --consumer.config /xxx/xxx/xxx/consumer.config.properties