Brett Konold created SAMZA-2493:
-----------------------------------
Summary: Keep checkpoint manager consumer open for repeated polling
Key: SAMZA-2493
URL: https://issues.apache.org/jira/browse/SAMZA-2493
Project: Samza
Issue Type: New Feature
Reporter: Brett Konold
Assignee: Brett Konold
Standby containers will need to continually poll for new checkpoint messages in
order to keep their changelog side inputs SSPs in sync with the active task's
checkpoints. Currently, KafkaCheckpointManager's underlying consumer is closed
after the first time checkpoints are read.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)