[jira] [Created] (APEXMALHAR-2523) In Kafka input operator, use committed() call instead of depending on exceptions to set the initial offset

Tue, 11 Jul 2017 12:00:20 -0700 

Venkata Rama Puppala created APEXMALHAR-2523:
------------------------------------------------

             Summary: In Kafka input operator, use committed() call instead of 
depending on exceptions to set the initial offset
                 Key: APEXMALHAR-2523
                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2523
             Project: Apache Apex Malhar
          Issue Type: Improvement
            Reporter: Venkata Rama Puppala


In Kafka input operator, use committed() call instead of depending on 
exceptions to set the initial offset.

This will help even when the reset strategies are set by the user. When reset 
strategy is set to value other than None, exception won't happen and offset 
would be set.




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

Reply via email to