使用Spring Cloud Stream Kafka活页夹重复消耗消息

问题描述 投票:0回答:1

[我们有一些使用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活页夹的微服务在它们之间进行通信。有时,我们会观察到消费者收到的重复消息的突发情况-经常...

spring-boot apache-kafka spring-kafka spring-cloud-stream spring-cloud-stream-binder-kafka
1个回答
1
投票

问这样的问题时,您应该显示您的配置。

© www.soinside.com 2019 - 2024. All rights reserved.