You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2015/10/22 02:22:27 UTC

[jira] [Resolved] (KAFKA-2230) Add a wakeup() call to the new consumer

     [ 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)