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

Posted to dev@kafka.apache.org by "Jay Kreps (JIRA)" <ji...@apache.org> on 2015/05/29 02:15:17 UTC

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

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)