RocketMQ拉不到数据

在本地获取的了数据，传上去就不行了。
我有三个Consumer，用的是广播模式，每个Consumer都订阅了三个Topic。

其中，Taobao的如下

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(RaceConfig.MetaConsumerGroup);

            consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);

            //consumer.setNamesrvAddr(RaceConfig.MqAddr);

            consumer.setMessageModel(MessageModel.BROADCASTING);

            try {
                consumer.subscribe(RaceConfig.MqTaobaoTradeTopic, "*");
                consumer.subscribe(RaceConfig.MqTmallTradeTopic, "*");
                consumer.subscribe(RaceConfig.MqPayTopic, "*");

                consumer.registerMessageListener(new MessageListenerConcurrently() {

                    @Override
                    public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs,
                                                                    ConsumeConcurrentlyContext context) {
                        for (MessageExt msg : msgs) {
                            if (!msg.getTopic().equals(RaceConfig.MqTaobaoTradeTopic)) {
                                continue;
                            }

                            //do something

                        }
                        return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
                    }
                });

                consumer.start();
            }
            catch (MQClientException e) {
                // ignore;
                e.printStackTrace();
            }

            System.out.println("Consumer Started.");