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
             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

Reply via email to