Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- sshuser@wn0:~$sudo bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list wn0.internal.cloudapp.net:9093 --topic TP.TOPIC --time -1 --offsets 1 --security-protocol SSL
- {metadata.broker.list=wn0.internal.cloudapp.net:9093, request.timeout.ms=1000, client.id=GetOffsetShell, security.protocol=SSL}
- [2017-09-26 19:21:59,026] WARN Fetching topic metadata with correlation id 0 for topics [Set(TP.TOPIC)] from broker [BrokerEndPoint(0,wn0.internal.cloudapp.net:9093)] failed (kafka.client.ClientUtils$)
- java.io.EOFException
- at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
- at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
- at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
- at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:84)
- at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:81)
- at kafka.producer.SyncProducer.send(SyncProducer.scala:126)
- at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
- at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:96)
- at kafka.tools.GetOffsetShell$.main(GetOffsetShell.scala:98)
- at kafka.tools.GetOffsetShell.main(GetOffsetShell.scala)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement