[GitHub] [rocketmq] leopardrota created a discussion: In broadcast mode, the consumer has successfully subscribed, but cannot consume messages. | 广播模式下，消费者订阅成功，但是消费不到消息

["leopardrota (via GitHub)" <gi...@apache.org>]

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

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. | 从这里可以看到确实订阅成功了。
![捕获](https://github.com/apache/rocketmq/assets/55968645/ab4e8e4e-294c-4007-a495-5682b42736c5)


GitHub link: https://github.com/apache/rocketmq/discussions/6981

----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org