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
