matthiaskraaz opened a new pull request, #15901: URL: https://github.com/apache/kafka/pull/15901
After a short discussion with Sophie Blee-Goldman (see https://lists.apache.org/thread/x4szs4szq0gq1twrpdv0fppzr92rr623), I dived into a few days of debugging and testing with a network connection that can deliberately switched to drop all packages. As I also work with Spring sometimes, I finally looked up how Spring Kafka does the exception handling and came up with quite a simple solution that at least works very well with my test scenarios: I used all the default timeouts for the configuration of the producer and tested with network outages (packages are dropped) of 20 seconds, 45 seconds and 75 seconds. While transforming my production code back into a code sample, I changed it from catching general Exceptions to catching KafkaExceptions, because Sophie mentioned she doesn't like general Exceptions to be caught. Please consider this PR as a request for comments, as I am rather new to Kafka and I didn't quite understand all the details of the original code sample. -- 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]
