操作场景
该任务指导您在购买 CKafka 服务后，使用 Kafka API。本地下载并解压 Kafka 工具包，并对 Kafka API 进行简单测试。
操作步骤
步骤1：安装 JDK 环境
1. 检查 Java 安装。
打开终端，执行如下命令：
java -version
2. 设置 Java 环境。
设置
JAVA_HOME 环境变量，并指向您机器上的 Java 安装目录。
以 Java JDK 1.8.0_20 版本为例，操作系统的输出如下：操作系统 | 输出 |
Windows | Set the environment variable JAVA_HOME to C:\\Program Files\\Java\\jdkjdk1.8.0_20 |
Linux | export JAVA_HOME=/usr/local/java-current |
Mac OSX | export JAVA_HOME=/Library/Java/Home |
将 Java 编译器地址添加到系统路径中：
操作系统 | 输出 |
Windows | 将字符串“;C:\\Program Files\\Java\\jdk1.8.0_20\\bin”添加到系统变量“Path”的末尾 |
Linux | export PATH=$PATH:$JAVA_HOME/bin/ |
Mac OSX | not required |
使用上面提到的
java -version 命令验证 Java 安装。步骤2：下载 Kafka 工具包
步骤3：Kafka API 测试
1. 在本地配置 ACL 策略。
1.1 在工具包
./config 目录下，在 producer.properties 和 consumer.properties 文件末尾添加以下内容：security.protocol=SASL_PLAINTEXTsasl.mechanism=PLAIN
1.2 创建一个名为 ckafka_client_jaas.conf 的文件，内容如下：
KafkaClient {org.apache.kafka.common.security.plain.PlainLoginModule requiredusername="yourinstance#yourusername"password="yourpassword";};
说明
username 是
实例 ID + # + 刚配置的用户名，password 是刚配置的用户密码。 1.3 在工具包
./bin 目录下，在 kafka-console-producer.sh 和 kafka-console-consumer.sh 文件起始部位增加对 JAAS 文件的路径的声明（必须是完整路径）：export KAFKA_OPTS="-Djava.security.auth.login.config=****/config/ckafka_client_jaas.conf"
2. 通过 CLI 命令生产和消费消息，去到
./bin目录下。2.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 管理页面获取。
2.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. 在 CKafka 控制台消息查询页面，查询刚刚发送的消息内容。
