Venkata Rama Puppala created APEXMALHAR-2521:
------------------------------------------------
Summary: Expose kafka's committed offset and latest offset in
Kafka input operator
Key: APEXMALHAR-2521
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2521
Project: Apache Apex Malhar
Issue Type: New Feature
Reporter: Venkata Rama Puppala
Can we expose the current committed offset and the latest offset (for the kafka
partitions an operator partition is processing) to an operator that extends the
kafka input operator. These can be used to determine the lag.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
