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)