Hi, I try to use the example https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example(and BTW where is 0.8.2 example?). It does not work, so I make a simplest possible snippet (still not working) out of coce for findLeader(). Here it is below, and it produces the error: Error communicating with Broker [127.0.0.1] to find Leader for [test, 0] Reason: java.io.EOFException: Received -1 when reading from channel, socket has likely been closed.null Which this igf I use console consumer (kafka-console-consumer.sh) with the same topic, localhost, port - it works, so broker is alive. Please help to find what's wrong. And the whole example: does somebody know how to fix it?
