Hi, I am learning kafka, ... hard way I try to run the example given here: https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example Whatever I do i I have java.nio.channels.ClosedChannelException when try to send message Exception in thread "main" java.nio.channels.ClosedChannelExceptionat kafka.network.BlockingChannel.send(BlockingChannel.scala:100)at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:78)at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:68) And, sometimes it's 2015-02-24 13:46:51 INFO SimpleConsumer:68 - Reconnect due to socket error: java.io.EOFException: Received -1 when reading from channel, socket has likely been closed. (in all cases it fails in findLeader())
At the same some other consumers work, as e.g. the command line console-consumer Now, I put a very small code snippet (below), that seems should do the job, but it's not, something missing. Please help. public class Test1 { public static void main(String[] args) {String host = "localhost"; int port = 2181; String topic = "test"; int soTimeout = -1; int bufferSize = 100000; String clientId = "me-aly"; SimpleConsumer consumer = new SimpleConsumer(host, port, soTimeout, bufferSize, clientId);List<String> topics = Collections.singletonList(topic); TopicMetadataRequest req = new TopicMetadataRequest(topics); kafka.javaapi.TopicMetadataResponse resp = consumer.send(req); System.out.println(resp); }}