[
https://issues.apache.org/jira/browse/APEXMALHAR-1928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved APEXMALHAR-1928.
--------------------------------------
Resolution: Fixed
> Update checkpointed offsettrack in operator thread instead of consumer thread
> -----------------------------------------------------------------------------
>
> Key: APEXMALHAR-1928
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-1928
> Project: Apache Apex Malhar
> Issue Type: Bug
> Reporter: Siyuan Hua
> Assignee: Siyuan Hua
> Fix For: 3.3.0
>
>
> The checkpointed offset is updated in consumer thread now. It is possible the
> message is consumed by kafka consumer but not necessarily emitted. When the
> operator comes back from a failure the messages in the holding buffer will be
> gone.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
