kafka.tools.getoffsetshell在kafka 1.0上启用kerberos安全性

lokaqttq  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(337)

我在kafka 1.0上启用了kerberos身份验证。当我尝试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--主题abdullah--时间-1
[2018-06-26 12:59:00058]从代理[brokerendpoint(0,klbirkfki19092)]获取主题[set(abdullah)]相关id为0的主题元数据失败(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中出现异常:从代理[arraybuffer(brokerendpoint(0,klbirkfki19092))]获取主题[set(abdullah)]的主题元数据失败

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--代理列表klbirkfki1:9092--主题abdullah--时间-1
[2018-06-26 12:59:00058]从代理[brokerendpoint(0,klbirkfki19092)]获取主题[set(abdullah)]相关id为0的主题元数据失败(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中出现异常:从代理[arraybuffer(brokerendpoint(0,klbirkfki19092))]获取主题[set(abdullah)]的主题元数据失败

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

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题