apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Venkata Rama Puppala (JIRA)" <j...@apache.org>
Subject [jira] [Created] (APEXMALHAR-2524) In kafka input operator commit errors are not handled correctly
Date Tue, 11 Jul 2017 19:21:00 GMT
Venkata Rama Puppala created APEXMALHAR-2524:
------------------------------------------------

             Summary: In kafka input operator commit errors are not handled correctly
                 Key: APEXMALHAR-2524
                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2524
             Project: Apache Apex Malhar
          Issue Type: Bug
    Affects Versions: 3.7.0
            Reporter: Venkata Rama Puppala


In kafka input operator commit errors are not handled correctly. 

When below exception happens, the consumer is not able to continue to poll/fetch messages
from kafka.
 
internals.ConsumerCoordinator (ConsumerCoordinator.java:handle(544)) - Error UNKNOWN_MEMBER_ID
occurred while committing offsets for group
org.apache.kafka.clients.consumer.CommitFailedException: Commit cannot be completed due to
group rebalance




--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message