Hello all,

I am trying to get consumer metadata from my Java program, using blocking
channel as described in this link
<https://cwiki.apache.org/confluence/display/KAFKA/Committing+and+fetching+consumer+offsets+in+Kafka>.
The problem is, I always got SocketTimeoutException but when I try to use
telnet to kafka server there is no problem.
Here is my program code :

>   BlockingChannel channel = new BlockingChannel(
>       KAFKA_SERVER,
>       KAFKA_SERVER_PORT,
>       BlockingChannel.UseDefaultBufferSize(),
>       BlockingChannel.UseDefaultBufferSize(),
>       FETCH_CONSUMER_METADATA_TIMEOUT);
>   channel.connect();
>   channel.send(new ConsumerMetadataRequest(GROUP_ID,
> ConsumerMetadataRequest.CurrentVersion(), random.nextInt(), CLIENT_ID));
>   this.consumerMetadataResponse =
> ConsumerMetadataResponse.readFrom(channel.receive().buffer());
>   channel.disconnect();


and here is the exception caught in program :

> java.net.SocketTimeoutException
> at sun.nio.ch.SocketAdaptor$SocketInputStream.read(SocketAdaptor.java:229)
> at sun.nio.ch.ChannelInputStream.read(ChannelInputStream.java:103)
> at
> java.nio.channels.Channels$ReadableByteChannelImpl.read(Channels.java:385)
> at kafka.utils.Utils$.read(Utils.scala:380)
> at
> kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
> at kafka.network.Receive$class.readCompletely(Transmission.scala:56)
> at
> kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:111)


Thank you,

-- 
Muqtafi Akhmad
Software Engineer
Traveloka

Reply via email to