Ananth created APEXCORE-472:
-------------------------------
Summary: Enhance Kafka 0.9 input operator to support starting from
custom offsets in multiple partitions
Key: APEXCORE-472
URL: https://issues.apache.org/jira/browse/APEXCORE-472
Project: Apache Apex Core
Issue Type: Improvement
Affects Versions: 3.3.1
Reporter: Ananth
Enhance Kafka 0.9 input operator to support starting from custom offsets in
multiple partitions
This is needed for multiple reasons:
Assuming kafka is hosting data that does not expire soon but after an extended
period of time by configuring the TTL :
Example use cases include
- Bugs introduced in a middle of a data stream from an upstream application
writing to kafka and downstream Apex app needs to process data
- Feature enhancements to business logic in an Operator that needs a code
update and need to process data from a certain time that a developer knows is
from a certain offset in kafka
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
