Xinyu Liu created SAMZA-2164:
--------------------------------
Summary: Close the consumer after reading checkpoints
Key: SAMZA-2164
URL: https://issues.apache.org/jira/browse/SAMZA-2164
Project: Samza
Issue Type: Bug
Reporter: Xinyu Liu
Assignee: Xinyu Liu
We read checkpoints at the start of a container for once. We should close the
consumer after that so it won't keep filling the BEM with checkpoints written
later. Currently I saw a lot of these checkpoint messages in the BEM.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
