search

rocketmq / rocketmq-spring-boot-starter

Help developers quickly integrate RocketMQ in Spring Boot. Support the Spring Message specification to facilitate developers to quickly switch from other MQ to RocketMQ.
https://www.rocketmq.org
Apache License 2.0
77 stars 22 forks source link

消费者组设置后启动 报 "重复的消费者" #4

Open johnnywjh opened 5 years ago

johnnywjh commented 5 years ago

场景 : 我写了一个demo , 最开始就一个 消费者 , 测试没问题, 注解上有写 consumerGroup 和 tag 改动 : 然后我复制了这个类,改了写类名, 然后改了下 consumerGroup 效果 : 启动报错 : Caused by: java.lang.IllegalArgumentException: 重复的消费者

这个是为什么啊? 消费者不应该是监听同样的 topic 和 tag 么?

johnnywjh commented 5 years ago

追加问题 : 那这个 消费者组 @RocketMQListener(topic = topic1, consumerGroup = "my-consumer_test-topic-1") 应该怎么用呢?