Looks like you might have bootstrap.servers pointed at Zookeeper. It should
point to the Kafka brokers instead. The behavior of poll() currently is to
block until the group's coordinator is found, but sending the wrong kind of
request to Zookeeper probably results in a server-side disconnect. In th
Calling the stand alone client (org.apache.kafka" % "kafka-clients" %
“0.9.0.0”) from Scala, consumer.poll never returns. I’ve tried both assign
TopicPartition and subscribe and various timeouts and I’ve quintuple checked
config properties. Here’s a Scala-Ide worksheet
val props = loadProper