en I poll the same topic using kafka-console-consumer.sh,
> console-consumer also hangs.
>
>
>
> Regards
> Muthu
>
>
> -Original Message-----
> From: Jason Gustafson [mailto:ja...@confluent.io]
> Sent: Friday, March 04, 2016 5:33 AM
> To: users@kafka.ap
console-consumer also hangs.
Regards
Muthu
-Original Message-
From: Jason Gustafson [mailto:ja...@confluent.io]
Sent: Friday, March 04, 2016 5:33 AM
To: users@kafka.apache.org
Subject: Re: Consumer deadlock
Hi there,
Just to clarify, is the broker still on 0.8? Unfortunately, the n
hread_name : " +
> Thread.currentThread().getName());
> recordCount++;
>
> }
> long endTime = System.currentTimeMillis();
> long duration = (endTime - startTime)/1000;
> System.out.println("## rate : " + recordCount/durati
System.out.println("## rate : " + recordCount/duration + "
msgs/sec on Consumer ID " + id);
}
} catch (WakeupException e) {
// ignore for shutdown
} finally {
consumer.close();
}
}
public void shutdown() {
consumer.wakeu
ions
> > to how it enforces that timeout).
> >
> > -Ewen
> >
> > On Wed, Mar 2, 2016 at 11:24 AM, Oleg Zhurakousky <
> > ozhurakou...@hortonworks.com> wrote:
> >
> >> Guys
> >>
> >> We have a consumer deadlock and he
hod (though it currently has some limitations
> to how it enforces that timeout).
>
> -Ewen
>
> On Wed, Mar 2, 2016 at 11:24 AM, Oleg Zhurakousky <
> ozhurakou...@hortonworks.com> wrote:
>
>> Guys
>>
>> We have a consumer deadlock and here is
can always specify timeouts
to the consumer's poll() method (though it currently has some limitations
to how it enforces that timeout).
-Ewen
On Wed, Mar 2, 2016 at 11:24 AM, Oleg Zhurakousky <
ozhurakou...@hortonworks.com> wrote:
> Guys
>
> We have a consumer deadlock and here
