如果生产者应用程序在发送到代理之前崩溃，生产者 'buffer.memory' 中的消息会怎样？
what happens to the messages in producer 'buffer.memory' if the producer app is crashed before they were sent to the broker?
我正在使用 spring-kafka 2.2.8 并使用以下设置编写一个简单的生产者：
linger.ms：5
max.block.ms: 60000
现在我的问题是，如果生产者应用程序在将消息发送到代理之前崩溃（尤其是在异步生产者调用模式下），生产者 'buffer.memory' 中的消息会发生什么情况？
是否有任何选项可以捕获这些消息的状态？
记录会丢失；您需要获取发送的 Future 的结果，以确保它们确实到达了代理。
我正在使用 spring-kafka 2.2.8 并使用以下设置编写一个简单的生产者： linger.ms：5 max.block.ms: 60000
现在我的问题是，如果生产者应用程序在将消息发送到代理之前崩溃（尤其是在异步生产者调用模式下），生产者 'buffer.memory' 中的消息会发生什么情况？
是否有任何选项可以捕获这些消息的状态？
记录会丢失；您需要获取发送的 Future 的结果，以确保它们确实到达了代理。