[ https://issues.apache.org/jira/browse/APEXMALHAR-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sandesh reassigned APEXMALHAR-2522: ----------------------------------- Assignee: Sandesh > Add support for specifying begin and end offsets for each partitions > -------------------------------------------------------------------- > > Key: APEXMALHAR-2522 > URL: https://issues.apache.org/jira/browse/APEXMALHAR-2522 > Project: Apache Apex Malhar > Issue Type: New Feature > Reporter: Venkata Rama Puppala > Assignee: Sandesh > > Add support for specifying begin and end offsets for different partitions > which when reached would result in the application shutting itself down. It > would be good to have the ability to set these dynamically. > Throw shutdown exception when committed offset reaches end offset. -- This message was sent by Atlassian JIRA (v6.4.14#64029)