Venkata Rama Puppala created APEXMALHAR-2522:
------------------------------------------------
Summary: 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
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)