You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Brett Konold (Jira)" <ji...@apache.org> on 2020/03/25 01:35:00 UTC

[jira] [Created] (SAMZA-2493) Keep checkpoint manager consumer open for repeated polling

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)