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); }}
