kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jason Gustafson (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-2683) Ensure wakeup exceptions are propagated to user in new consumer
Date Thu, 22 Oct 2015 00:32:27 GMT
Jason Gustafson created KAFKA-2683:
--------------------------------------

             Summary: Ensure wakeup exceptions are propagated to user in new consumer
                 Key: KAFKA-2683
                 URL: https://issues.apache.org/jira/browse/KAFKA-2683
             Project: Kafka
          Issue Type: Bug
            Reporter: Jason Gustafson
            Assignee: Jason Gustafson


KafkaConsumer.wakeup() can be used to interrupt blocking operations (e.g. in order to shutdown),
so wakeup exceptions must get propagated to the user. Currently, there are several locations
in the code where a wakeup exception could be caught and silently discarded. For example,
when the rebalance callback is invoked, we just catch and log all exceptions. In this case,
we also need to be careful that wakeup exceptions do not affect rebalance callback semantics.
In particular, it is possible currently for a wakeup to cause onPartitionsRevoked to be invoked
multiple times.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message