在rocketmq中使用集群时如何设置用户名和密码？

# 创建 AccessKey
sh mqadmin updateSubCommandKey -n <namesrvAddr> -t <topic> -s <subName> -c <clusterName> -u <username> -p <password> -k <accessKey> -l <secretKey>

import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.common.message.Message;

public class ProducerWithAuth {
    public static void main(String[] args) throws MQClientException {
        DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName");
        producer.setNamesrvAddr("<namesrvAddr>");
        producer.setAccessKey("<accessKey>");
        producer.setSecretKey("<secretKey>");

        producer.start();

        try {
            Message msg = new Message("<topic>", "TagA", "Hello RocketMQ".getBytes(RemotingHelper.DEFAULT_CHARSET));
            SendResult sendResult = producer.send(msg);
            System.out.printf("%s%n", sendResult);
        } catch (Exception e) {
            e.printStackTrace();
        }

        producer.shutdown();
    }
}