Jay Kreps created KAFKA-2230:
--------------------------------
Summary: Add a wakeup() call to the new consumer
Key: KAFKA-2230
URL: https://issues.apache.org/jira/browse/KAFKA-2230
Project: Kafka
Issue Type: Improvement
Reporter: Jay Kreps
The consumer is meant to be used in an event loop where you poll with some
timeout. There are sometime instances where you want the consumer to stop
waiting on I/O and wake up and do something (like shut down or tell you the
offset or whatever) it would be good to add an api like
wakeup()
to the consumer to allow the client to do this.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
