Hi,
you are programatically shutting down the executor after 10 seconds
try {
Thread.sleep(1);
} catch (InterruptedException ie) {
}
example.shutdown();
if you do not execute this code your threads will run forever.
Davide B.
--
ms =
> consumerMap.get(topic);*
>
>
>
> *// now launch all the threads*
>
> *//*
>
> *executor =
> Executors.newFixedThreadPool(a_numThreads);*
>
>
>
> *// now create an object to consume the messages*
>
> *
// now launch all the threads*
>
> *//*
>
> *executor =
> Executors.newFixedThreadPool(a_numThreads);*
>
>
>
> *// now create an object to consume the messages*
>
> *//*
>
Session termination can happen either when client or zookeeper process
pauses (due to GC) or when the client process terminates. A sustainable
solution is to tune GC settings. For now, you can try increasing the
zookeeper.session.timeout.ms.
On Sun, Mar 9, 2014 at 3:44 PM, Ameya Bhagat wrote:
I am using a high level consumer as described at:
https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example
I am noticing that my consumer does not run forever and ends after some
time (< 15s). At the zookeeper side, I see the following:
INFO Processed session termination for sessi
