apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Siyuan Hua (JIRA)" <j...@apache.org>
Subject [jira] [Created] (APEXMALHAR-2363) Kafka input operator needs a force exit in case it can't recover from application offsets
Date Thu, 01 Dec 2016 18:42:00 GMT
Siyuan Hua created APEXMALHAR-2363:
--------------------------------------

             Summary: Kafka input operator needs a force exit in case it can't recover from
application offsets
                 Key: APEXMALHAR-2363
                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2363
             Project: Apache Apex Malhar
          Issue Type: Improvement
            Reporter: Siyuan Hua


Nowadays, when the initial offset of kafka is set to APPLICATION_OR_LATEST, and if some reason
the consumer is temporarily not able to resume from application offset, it will fall into
latest offset immediately.  
We should 1. give it a retry option
2. give a force exit option



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

Mime
View raw message