[SAMZA-2493] Keep checkpoint manager consumer open for repeated polling

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.5
• Assignee: Brett Konold
• Reporter: Brett Konold
• Created: 25/Mar/20 01:34
• Updated: 27/May/20 03:50
• Resolved: 27/May/20 03:50

Description

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.

Issue Links

• links to: GitHub Pull Request #1327