kengan opened a new issue #339:
URL: https://github.com/apache/rocketmq-spring/issues/339
I have setup a rocketmq cluster with 2 master and 1 namesrv.
I make 2 consumer program with rocketmq-spring-boot-starter 2.2.0 and
Spring boot 2.3.8. The main program abouot consumer is as following:
package com.cesc.iot.handle.handler;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQReplyListener;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
@Service
@RocketMQMessageListener(topic = "${iot.rocketmq.topic}", consumerGroup =
"iot_message_consumer")
public class IotMessageHandler implements
RocketMQReplyListener<String,String> {
private static final Logger logger =
LoggerFactory.getLogger("BackgroundLogger");
@Override
public String onMessage(String message) {
logger.info("recevice message from mq:"+message);
return "ok";
}
}
But I found that 2 consumer only consume the message in a broker.
When stop one broker every thing is OK, but when I open two broker, some
message in other broker can not be consume. Please see the following image
about rocketmq-console
Can you tell me why？ Thank you
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
