[
https://issues.apache.org/jira/browse/APEXMALHAR-2521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sandesh reassigned APEXMALHAR-2521:
-----------------------------------
Assignee: Sandesh
> 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
> Assignee: Sandesh
>
> 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)
