мой rocketMQ 2m-noslave не может сообщения потребителя

Я создаю сервер rocketmq на своем сервере, это кластер 2m-noslave, он может отправлять сообщения на rocketmq, но мой потребитель не может получить сообщение, кто-то скажет мне, где не так, думает ... это мой код потребительского класса:

public class Consumer{

    public static final String CONSUMER_GROUP_NAME = "broker-b";
    public static final String CLUSTER_ADDR = "120.27.128.207:9876;120.27.146.42:9876";
    public static final String SUBSCRIBE = "dzg_topic_001";

    private void consumerMessage() throws MQClientException {
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(CONSUMER_GROUP_NAME);
        consumer.setNamesrvAddr(CLUSTER_ADDR);
        consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
        consumer.setMessageModel(MessageModel.CLUSTERING);
        //设置批量消费个数
        consumer.subscribe(SUBSCRIBE, "*");

        consumer.registerMessageListener((List<MessageExt> msgList, ConsumeConcurrentlyContext context)->{
            MessageExt msg = msgList.get(0);
            System.out.println( "received new message:  topic===="+msg.getTopic()+"  tag==="+msg.getTags()+"  body=="+new String(msg.getBody()));
            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
        });
        consumer.start();
        System.out.println("ConsumerStarted.");

    }


    public static void main(String[] args) {
        try {
            new Consumer().consumerMessage();
        } catch (MQClientException e) {
            e.printStackTrace();
        }
    }


}

а мой сервер rocketmq - введите здесь описание изображения