Not sure what was wrong in my remote kafka cluster as i haven't received any exceptions from my consumer side. I tried to connect my local kafka server and things are working (at least I got some exceptions saying "The session timeout is not within an acceptable range." etc..)
Thanks all for the help.. On 30 March 2016 at 12:06, Ratha v <vijayara...@gmail.com> wrote: > Looks like this particular block runs forever.. > > @AbstractCoordinator.class > > /** > > * Block until the coordinator for this group is known. > > */ > > public void ensureCoordinatorKnown() { > > while (coordinatorUnknown()) { > > RequestFuture<Void> future = sendGroupMetadataRequest(); > > client.poll(future); > > > if (future.failed()) { > > if (future.isRetriable()) > > client.awaitMetadataUpdate(); > > else > > throw future.exception(); > > } > > } > > } > > > > @ ConsumerNetworkClient class "*requestsSent *returns* false @*trySend() > *" *any idea? > > > > *@ ConsumerNetworkClient.class* > > > private boolean trySend(long now) { > > // send any requests that can be sent now > > boolean requestsSent = false; > > for (Map.Entry<Node, List<ClientRequest>> requestEntry: > unsent.entrySet()) > { > > Node node = requestEntry.getKey(); > > Iterator<ClientRequest> iterator = requestEntry > .getValue().iterator(); > > while (iterator.hasNext()) { > > ClientRequest request = iterator.next(); > > if (client.ready(node, now)) { > > client.send(request, now); > > iterator.remove(); > > requestsSent = true; > > } > > } > > } > > return requestsSent; > > On 30 March 2016 at 11:41, Ratha v <vijayara...@gmail.com> wrote: > >> And no error logs at kafka server..I expect any exception from my end, >> but I'm not getting any exception :( >> >> On 30 March 2016 at 11:39, Ratha v <vijayara...@gmail.com> wrote: >> >>> Hi Shrijeet ; >>> I checked the kafka communication layer,( tcp dumps) and I can see >>> some packets are received by kafka server.. >>> That means communication works fine. >>> >>> Only issue is in my polling:( >>> >>> *Thanks..* >>> >>> On 30 March 2016 at 10:54, Shrijeet Paliwal <shrijeet.pali...@gmail.com> >>> wrote: >>> >>>> The consumer script is using old consumer which connects via zookeeper, >>>> so >>>> its not the same. The reason I asked because I recall poll(timeout) >>>> getting >>>> stuck forever if it can't reach broker. >>>> >>>> -- >>>> Shrijeet >>>> >>>> On Tue, Mar 29, 2016 at 4:51 PM, Ratha v <vijayara...@gmail.com> wrote: >>>> >>>> > Yes... (I checked, hostname and port, and i believe thats correct >>>> because >>>> > consumer.sh script also working?) >>>> > #* ./kafka-console-consumer.sh --zookeeper xxx:2181 --topic mytopic* >>>> > >>>> > On 30 March 2016 at 10:29, Shrijeet Paliwal < >>>> shrijeet.pali...@gmail.com> >>>> > wrote: >>>> > >>>> > > On Tue, Mar 29, 2016 at 4:19 PM, Ratha v <vijayara...@gmail.com> >>>> wrote: >>>> > > >>>> > > > 9092 >>>> > > >>>> > > >>>> > > Are your brokers listening at this port? >>>> > > >>>> > > -- >>>> > > Shrijeet >>>> > > >>>> > >>>> > >>>> > >>>> > -- >>>> > -Ratha >>>> > http://vvratha.blogspot.com/ >>>> > >>>> >>> >>> >>> >>> -- >>> -Ratha >>> http://vvratha.blogspot.com/ >>> >> >> >> >> -- >> -Ratha >> http://vvratha.blogspot.com/ >> > > > > -- > -Ratha > http://vvratha.blogspot.com/ > -- -Ratha http://vvratha.blogspot.com/