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

pluginPath=/path/to/your/plugin

public class MyAuthenticationPlugin implements AuthenticationPlugin {
    @Override
    public void authenticate(RemotingCommand request, Channel channel) throws AuthenticationException {
        // 获取请求中的用户名和密码
        String username = request.getExtFields().get("username");
        String password = request.getExtFields().get("password");

        // 根据自定义逻辑验证用户名和密码
        if (!isValid(username, password)) {
            throw new AuthenticationException("Invalid username or password");
        }
    }

    private boolean isValid(String username, String password) {
        // 自定义验证逻辑
        // 返回true表示验证通过，返回false表示验证失败
    }
}

brokerPlugins=custom.plugin.MyAuthenticationPlugin