消息队列 CKafka 版运行 Kafka 客户端（可选）

操作场景
在控制台上完成实例、Topic 等资源配置后，您也可以通过下载并解压 Kafka 工具包，并对 Kafka API 进行简单的收发消息测试。
前提条件
已完成前期的 CKafka 资源创建。
已参考准备工作完成环境配置。
操作步骤
1. 下载并解压 Kafka 安装包（Kafka 安装包官网下载地址）。
2. 在本地配置 ACL 策略。
2.1 在工具包 ./config 目录下，在 producer.properties 和 consumer.properties 文件末尾添加以下内容：
security.protocol=SASL_PLAINTEXT 
sasl.mechanism=PLAIN
2.2 创建一个名为 ckafka_client_jaas.conf 的文件，内容如下：
KafkaClient {
           org.apache.kafka.common.security.plain.PlainLoginModule required
           username="yourinstance#yourusername"
           password="yourpassword";
};
说明：
username 是实例 ID + # + 刚配置的用户名，password 是刚配置的用户密码。   
2.3 在工具包 ./bin 目录下，在 kafka-console-producer.sh 和 kafka-console-consumer.sh 文件起始部位增加对 JAAS 文件的路径的声明（必须是完整路径）：
export KAFKA_OPTS="-Djava.security.auth.login.config=****/config/ckafka_client_jaas.conf"
3. 通过 CLI 命令生产和消费消息。
3.1 打开终端启动消费者。
bash kafka-console-consumer.sh --bootstrap-server XXXX:port --topic XXXX --consumer.config ../config/consumer.properties
说明：
broker-list：将 XXXX:port 替换成公网访问的域名与端口，在控制台实例详情页面的接入方式模块获取。
﻿
topic：将 XXXX 替换成 topic 名称，在控制台 topic 管理页面获取。
3.2 另外开一个终端窗口启动生产者。
 bash kafka-console-producer.sh --broker-list XXXX:port --topic XXXX --producer.config ../config/producer.properties
说明：
broker-list：将 XXXX:port 替换成公网访问的域名与端口，在控制台实例详情页面的接入方式模块获取。
﻿
topic：将 XXXX 替换成 topic 名称，在控制台 topic 管理页面获取。
3.3 输入消息内容之后按回车，即可看到消费端也几乎同时收到消息。
生产消息：
﻿
﻿
﻿
消费消息：
﻿
﻿
﻿
﻿
运行 Kafka 客户端（可选）

本页目录：

操作场景

前提条件

操作步骤
