search

dyc87112 / blog-comments

5 stars 1 forks source link

Spring Cloud Stream如何处理消息重复消费 | 程序猿DD #296

Open dyc87112 opened 5 years ago

dyc87112 commented 5 years ago

http://blog.didispace.com/spring-cloud-starter-dalston-7-5/

最近收到好几个类似的问题：使用Spring Cloud Stream操作RabbitMQ或Kafka的时候，出现消息重复消费的问题。通过沟通与排查下来主要还是用户对消费组的认识不够。其实，在之前的博文以及《Spring Cloud微服务实战》一书中都有提到关于消费组的概念以及作用。 那么什么是消费组呢？为什么要用消费组

telami commented 5 years ago

nice

chenzule commented 5 years ago

这个我们遇到了重复消费的问题，而且确认不是group 导致的，后续发现是spring cloud 和stream 的版本不一致导致的

dudiao commented 5 years ago

使用springcloud stream，APP1向APP2发送消息，APP2收到消息后将确认消息反馈给APP1，这种情况在APP1、APP2多实例下，怎么保证消息不被重复消费呢

17097201102 commented 5 years ago

output如果一个topic有多个组，output的端，怎么写入组名

tutuerhao commented 5 years ago

数据持久化和ack确认怎么搞啊

0415wangyibo commented 5 years ago

这个只发送一次消息还好，发送第二次，就报错了，感觉写法上哪里有问题，而且不管有没有分组，都没出现过一个实例接收到另一个实例发送的消息的情况

lijianfx commented 5 years ago

大师你好，本片博文中给出的例子中，接收者、发送者绑定的都是名为example-topic的消息通道，但是在【消息驱动的微服务（消费组）】一文中，接收者绑定了名为input的消息通道，而生产者绑定的是名为output的消息通道，并且也能正常消费消息。请问这是为什么？小白求指教。

852675742 commented 5 years ago

请问怎么配置ConfirmCallback 回调