spring-kafka - 如果生产者应用程序在发送到代理之前崩溃，生产者“buffer.memory”中的消息会发生什么？

Question

我正在使用 spring-kafka 2.2.8 并使用以下设置编写一个简单的生产者： linger.ms : 5 max.block.ms: 60000

现在我的问题是，如果生产者应用程序在发送到代理之前崩溃（尤其是在异步生产者调用模式下），生产者“buffer.memory”中的消息会发生什么？

是否有任何选项可以捕获这些消息的状态？

标签： spring-kafka

Answer 1

记录将丢失；您需要获取Future发送的结果，以确保它们实际到达代理。