私のrocketMQ 2m-noslaveはコンシューマーメッセージを受信できません

Question

私は自分のサーバーにrocketmq serveiceを構築します.2m-noslaveクラスターです。それはrocketmqにメッセージを送ることができますが、私の消費者はメッセージを受け取ることができません。 ...これは私の Consumerクラスのコードであると考えて：私は財産autoCreateTopicEnableとautoCreateSubscriptionGroup'svalueがtrueに設定する場合

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サーバがenter image description here

Answer 1

である理由はfalseを設定し、消費者は、権利であります消費者は働くことができないのですか？