After doing some debugging, I found out that consumer metadata request
message has been sent to kafka broker but broker doesn't return any result
until timeout
I tried to restart kafka broker and finally it works.

Is there any explanation for this?

Thank you,

On Mon, Nov 2, 2015 at 10:39 AM, Muqtafi Akhmad <muqt...@traveloka.com>
wrote:

> 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
>
>


-- 
Muqtafi Akhmad
Software Engineer
Traveloka

Reply via email to