kafka.tools.GetOffsetShell с включенным Kerberos Security на Kafka 1.0 - PullRequest
0 голосов
/ 26 июня 2018

Я включил аутентификацию Kerberos на Kafka 1.0. Когда я пытаюсь выполнить kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list: 9092 --topic --time -1, возникает ошибка. Вот ошибка,

[kafka @ KLBIRKFKI1 kafka_2.11-1.0.1] $ bin / kafka-run-class.sh kafka.tools.GetOffsetShell - список брокеров klbirkfki1: 9092 --topic Абдулла - время -1

[2018-06-26 12: 59: 00,058] WARN Извлечение метаданных темы с идентификатор корреляции 0 для тем [Set (abdullah)] от брокера [BrokerEndPoint (0, klbirkfki1,9092)] не удалось (kafka.client.ClientUtils $)

java.io.EOFException

    at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:124)

    at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:131)

    at kafka.network.BlockingChannel.receive(BlockingChannel.scala:122)

    at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:82)

    at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:79)

    at kafka.producer.SyncProducer.send(SyncProducer.scala:124)

    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:63)

    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:98)

    at kafka.tools.GetOffsetShell$.main(GetOffsetShell.scala:79)

    at kafka.tools.GetOffsetShell.main(GetOffsetShell.scala)

Исключение в потоке "main" kafka.common.KafkaException: получение метаданных темы для тем [Set (abdullah)] из посредника [ArrayBuffer (BrokerEndPoint (0, klbirkfki1,9092))] не удалось

    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:77)

    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:98)

    at kafka.tools.GetOffsetShell$.main(GetOffsetShell.scala:79)

    at kafka.tools.GetOffsetShell.main(GetOffsetShell.scala)

Причина: java.io.EOFException

    at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:124)

    at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:131)

    at kafka.network.BlockingChannel.receive(BlockingChannel.scala:122)

    at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:82)

    at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:79)

    at kafka.producer.SyncProducer.send(SyncProducer.scala:124)

    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:63)

    ... 3 more

[kafka @ KLBIRKFKI1 kafka_2.11-1.0.1] $ bin / kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list klbirkfki1: 9092 --topic abdullah - время -1

[2018-06-26 12: 59: 00,058] WARN Не удалось получить метаданные темы с идентификатором корреляции 0 для тем [Set (abdullah)] из посредника [BrokerEndPoint (0, klbirkfki1,9092)] (kafka.client.ClientUtils) $)

java.io.EOFException

    at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:124)

    at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:131)

    at kafka.network.BlockingChannel.receive(BlockingChannel.scala:122)

    at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:82)

    at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:79)

    at kafka.producer.SyncProducer.send(SyncProducer.scala:124)

    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:63)

    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:98)

    at kafka.tools.GetOffsetShell$.main(GetOffsetShell.scala:79)

    at kafka.tools.GetOffsetShell.main(GetOffsetShell.scala)

Исключение в потоке "main" kafka.common.KafkaException: получение метаданных темы для тем [Set (abdullah)] из посредника [ArrayBuffer (BrokerEndPoint (0, klbirkfki1,9092))] не удалось

    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:77)

    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:98)

    at kafka.tools.GetOffsetShell$.main(GetOffsetShell.scala:79)

    at kafka.tools.GetOffsetShell.main(GetOffsetShell.scala)

Вызвано: java.io.EOFException

    at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:124)

    at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:131)

    at kafka.network.BlockingChannel.receive(BlockingChannel.scala:122)

    at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:82)

    at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:79)

    at kafka.producer.SyncProducer.send(SyncProducer.scala:124)

    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:63)

    ... 3 more
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...