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)

Reply via email to