If you do not expect the consumer to stop due to no more data coming with a
time out exception, then you would try/catch the exception. On the other
hand, throwing the timeout exception does not necessarily stop the
background fetcher threads, if you really want to shut down the consumer
you need to use the shutdown() API.
On Sun, Jun 29, 2014 at 11:36 PM, Daniel Compton <[EMAIL PROTECTED]>