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/
