In broadcast mode, the consumer has successfully subscribed, but cannot consume messages. | 广播模式下，消费者订阅成功，但是消费不到消息

[leopardrota]

In broadcast mode, the consumer has successfully subscribed, but cannot consume messages. I can't find the reason. | 广播模式下，消费者订阅成功，但是消费不到消息。找不到原因。

RocketMQ 4.9.4
rocketmq-client 4.9.5

Producer:

DefaultMQProducer producer = new DefaultMQProducer("fwcxGroup");
producer.setNamesrvAddr("127.0.0.1:9876");
producer.start();
try {
    Message msg = new Message("TEST-TOPIC-TCP-BROADCAST2",
        "Hello world".getBytes(RemotingHelper.DEFAULT_CHARSET)
    );
    producer.send(msg);
} catch (Exception e) {
    e.printStackTrace();
}
producer.shutdown();

Consumer:

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("broadcast-fwcxGroup");
consumer.setNamesrvAddr("127.0.0.1:9876");
consumer.setMessageModel(MessageModel.BROADCASTING);
consumer.subscribe("TEST-TOPIC-TCP-BROADCAST2", "*");
consumer.registerMessageListener(new MessageListenerConcurrently() {
    @Override
    public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs,
        ConsumeConcurrentlyContext context) {
        // This log can't be printed in the console. | 控制台没有输出消费日志。
        System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs);
        return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
    } });

consumer.start();
System.out.printf("Broadcast Consumer Started.%n");

It can be seen from here that the subscription was indeed successful. | 从这里可以看到确实订阅成功了。