[GitHub] [rocketmq] baigod opened issue #438: 广播消费时消费点位问题

Thu, 30 Aug 2018 20:26:53 -0700 

问题： 我创建了一个消费监听，代码如下


```java
// 创建消费实例
        @Bean(initMethod = "start", destroyMethod = "shutdown")
        public DefaultMQPushConsumer rocketMQUserCudConsumer() throws 
MQClientException {
                DefaultMQPushConsumer consumer = new 
DefaultMQPushConsumer(rocketMQProperties.getConsumerId());
                consumer.setNamesrvAddr(rocketMQProperties.getNamesrv());
                consumer.setMessageModel(MessageModel.BROADCASTING); // 广播消费
                
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
                // 1分钟前开始消费
                
consumer.setConsumeTimestamp(UtilAll.timeMillisToHumanString3(DateHelper.getTimestamp().getTime()
 - (1000 * 60 * 1)));

                consumer.subscribe(“T_MATCH_SIGNAL_DEV”, "*");
                consumer.registerMessageListener(new 
MessageListenerConcurrently() {

                        @Override
                        public ConsumeConcurrentlyStatus 
consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
                                //do something
                                LOGGER.info("{} consume_success", topic);
                                return 
ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
                        }
                });
                return consumer;
        }
`

在测试环境测试时，都正常消费并打印日志
![image](https://user-images.githubusercontent.com/23446974/44891184-8824df80-ad10-11e8-9e74-14d7b474a6aa.png)

但是在rocketmq-console里显示消费点位（consumerOffset） 都是0，看起来像是全部堆积的样子
![image](https://user-images.githubusercontent.com/23446974/44891212-b1de0680-ad10-11e8-86e6-42f7542f7eed.png)


请问这是属于bug还是正常的？



[ Full content available at: https://github.com/apache/rocketmq/issues/438 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to