请教一下，rocketmq5.x的广播消费者怎么创建的？

在RocketMQ 5.x版本中，广播消费者（Broadcast Consumer）通过创建PushConsumer对象，并在该对象上设置相应的属性来实现。

以下是使用Java客户端创建广播消费者的示例代码：

import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;

public class BroadcastConsumerExample {
    public static void main(String[] args) throws Exception {
        // 创建PushConsumer对象，并指定消费者组名
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("your_consumer_group_name");

        // 设置NameServer地址
        consumer.setNamesrvAddr("your_nameserver_address");

        // 设置消息消费模式为广播模式
        consumer.setMessageModel(MessageModel.BROADCASTING);

        // 设置消息拉取策略，从最新位置开始消费
        consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET);

        // 设置消息监听器
        consumer.registerMessageListener((List<MessageExt> msgs, ConsumeConcurrentlyContext context) -> {
            // 处理消息的业务逻辑
            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
        });

        // 启动消费者
        consumer.start();

        System.out.println("Broadcast Consumer started.");
    }
}