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/
