You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@apex.apache.org by "Siyuan Hua (JIRA)" <ji...@apache.org> on 2016/12/01 18:42:00 UTC
[jira] [Created] (APEXMALHAR-2363) Kafka input operator needs a
force exit in case it can't recover from application offsets
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)