mynameborat commented on PR #1674: URL: https://github.com/apache/samza/pull/1674#issuecomment-1603369836
> > 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. I meant `SystemConsumer` shutdown. For standalone, the containers are recreated on every rebalance. It is possible that the previous attempts to shutdown the container failed and perhaps, that is being ignored in the application -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
