[我们有一些使用Spring Boot和Spring Cloud Stream Kafka活页夹的微服务在它们之间进行通信。
[有时,我们会观察到消费者收到的重复消息的突发情况-通常是在第一次(成功)使用和处理后几天。
虽然我了解到Kafka不保证一次发送完全正确,但鉴于经纪人或服务日志中没有任何重新平衡事件或任何“可疑”活动,它看起来仍然很奇怪。由于使用者正在与外部API进行交互,因此使其具有幂等性有点困难。
任何提示可能是重复的原因?我应该寻找什么来解决这个问题?
[我们使用的是Kafka经纪人1.0.0,这个特定的消费者使用的是基于kafka-client 1.0.2(其他服务的版本可能有所不同)的Spring Cloud Stream Binder Kafka 2.0.0。
[我们有几个使用Spring Boot和Spring Cloud Stream Kafka活页夹的微服务在它们之间进行通信。有时,我们会观察到消费者收到的重复消息的突发情况-经常...
问这样的问题时,您应该显示您的配置。