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/

Reply via email to