Hi,
I am just wondering if the below snippet
ConsumerIteratori.e. by setting a consumer timeout, catching it and again just waiting
for the next message make it more robust?
Regards,
Rahul.
default, it.hasNext() blocks when there is no more message to consume.
So catching ConsumerTimeoutException doesn't make any difference. You only
need to handle ConsumerTimeoutException if you have customized the consumer
timeout config.
Thanks,
Jun
On Thu, Nov 27, 2014 at 7:48 AM, Rahul A
Consider the high level consumer example
https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example.
Using JAVA API, Is it possible to fetch the consumer id for this
particular consumer as displayed in ConsumerOffsetCheck "Owner" field?
Thanks,
Rahul.
