ryucc commented on PR #1674: URL: https://github.com/apache/samza/pull/1674#issuecomment-1603366596
> I don't think there is any problem with the existing code. For active containers, the expected behavior is to keep the `KafkaCheckpointManager` started until the entire container is shutdown which would trigger stop. This PR doesn't change when `KafkaCheckpointManager` is shutdown. The PR is trying to address that when `KafkaCheckpointManager` is shutdown, `SystemConsumer` is left open. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@samza.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
