分布式消息Kafka使用SASL 认证协议来实现身份验证的能力，加密的主题需要经过身份校验才能正常地消费和生产消息。

1. 创建用户并配置用户权限

   进入应用用户管理界面，新建用户，并给用户添加主题和消费组的权限，并且下载密钥。详细操作可以查看用户指南-创建应用用户。

   

   

2. 运行生产者客户端

   如下是Java客户端代码示例，注意修改内容（用户、密码、接入地址、主题名称）。

   

3. 运行消费者客户端

   如下是Java客户端代码示例，注意修改内容（用户、密码、接入地址、消费组名称、主题名称）。