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

Posted to commits@samza.apache.org by "Bharath Kumarasubramanian (Jira)" <ji...@apache.org> on 2020/05/27 03:51:00 UTC

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

     [ https://issues.apache.org/jira/browse/SAMZA-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Bharath Kumarasubramanian resolved SAMZA-2493.
----------------------------------------------
    Fix Version/s: 1.5
       Resolution: Fixed

> 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
>            Priority: Major
>             Fix For: 1.5
>
>          Time Spent: 2h 40m
>  Remaining Estimate: 0h
>
> 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)