Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Stopping thread on consumer timeout


Copy link to this message
-
Re: Stopping thread on consumer timeout
Hi Daniel,

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.

Guozhang
On Sun, Jun 29, 2014 at 11:36 PM, Daniel Compton <[EMAIL PROTECTED]>
wrote:
 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB