hamburml commented on PR #13619: URL: https://github.com/apache/kafka/pull/13619#issuecomment-2288237016
Hi @rvansa, we use Quarkus for AWS Lambdas and have SnapStart active, so a snapshot is created when the lambda is started and is reloaded during coldstart which makes coldstart very fast. We use smallrye-messaging and kafka connector to send messages to a kafka. After the coldstart we always get an exception that the connection is lost. The client reconnects and everything works. Of course the connection is lost because when AWS took the snapshot there was one working connection open. When the lambda is used 2 hours later this connection does not exist anymore. So we would appreciate this feature :) A simple close and reconnect method on a kafkaClient would work, which could be called before the checkpoint is created and afterRestore. https://github.com/quarkusio/quarkus/issues/42286 Cheers Michael -- 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]
