Advertisement
Guest User

Untitled

a guest
Sep 26th, 2017
85
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.26 KB | None | 0 0
  1. 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
  2.  
  3. {metadata.broker.list=wn0.internal.cloudapp.net:9093, request.timeout.ms=1000, client.id=GetOffsetShell, security.protocol=SSL}
  4. [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$)
  5. java.io.EOFException
  6. at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
  7. at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
  8. at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
  9. at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:84)
  10. at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:81)
  11. at kafka.producer.SyncProducer.send(SyncProducer.scala:126)
  12. at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
  13. at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:96)
  14. at kafka.tools.GetOffsetShell$.main(GetOffsetShell.scala:98)
  15. at kafka.tools.GetOffsetShell.main(GetOffsetShell.scala)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement