① 登录华为云控制台。选择“计算 > 弹性云服务器”，创建一台弹性云服务器（ECS），建议选择windows服务器。
② 下载和安装开发工具：Eclipse3.6.0以上版本，JDK1.8.111以上版本。

① ECS需要绑定一个弹性IP，具备外网访问权限，用于安装Eclipse和JDK。
② 如果用户已有ECS，可重复使用，无需多次创建。

① 控制台选择“应用服务 > 分布式消息服务 DMS”。单击右上角“创建队列”。
② 填写队列名称，选择队列类型为“Kafka队列”，选择队列模式。单击“确定”，创建队列。

① 确认当前区域为您应用服务部署的区域，如果不一致，请单击控制台左上角的区域图标进行切换。

① 队列创建完成后，单击队列名称，进入队列详情页。
② 单击“创建消费组”，填写消费组名称，完成消费组创建。

① 队列详情页的上方显示了Kafka Topic，下方显示了消费组ID。在生产与消费消息时使用这几项识别Kafka队列以及消费组。
② 一个队列默认可以创建3个消费组，队列和消费组的模式帮助服务架构解耦。。

① 单击控制台右上角的用户名，进入“账号中心”，在“基本信息”中单击“管理我的凭证”。
② 在“我的凭证”页中获取项目ID以及访问密钥（AK/SK），用于Kafka队列Demo示例工程配置。

① 分布式消息服务使用华为云IAM服务进行身份识别，保证队列和消息的安全。
②AK/SK密钥对如果已申请，可以使用原有AK/SK。

① 登录ECS，下载demo示例包（含SDK）。
② 导入工程，选择“Exiting Projects Into Workspace”方式导入。
③ 将获取到的队列Topic、消费组ID、项目ID以及AK/SK等信息替换到配置文件中。具体配置请参见运行示例工程。

① 工程包含了DMS Kafka（非专享版）的SDK文件以及demo示例代码。

① 编译工程，也可设置为Build Automatically。
② 运行DMSKafkaProducerDemo类，生产消息。
③ 运行DMSKafkaconsumerDemo类，从消费组消费消息。

① 在控制台可以查看队列和消费组的消息数变化。
② Demo工程可以正常生产和消费消息，则说明队列、消费组以及本地环境配置均正确。开发者可以参考Demo进行开发和对接分布式消息服务。