[
https://issues.apache.org/jira/browse/KAFKA-2230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-2230.
------------------------------------
Resolution: Fixed
This was added in KAFKA-2168.
> 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)
