操作场景
在控制台上完成实例、Topic 等资源配置后,您也可以通过下载并解压 Kafka 工具包,并对 Kafka API 进行简单的收发消息测试。
前提条件
已完成前期的 CKafka 资源创建。
已参考准备工作完成 Linux 服务器准备和环境配置。
操作步骤
1. 下载并解压 Kafka 安装包(Kafka 安装包官网下载地址)。
2. 将下载下来的 Demo 上传到同一个 VPC 下的 Linux 服务器,然后登录 Linux 服务器。
3. 通过 CLI 命令生产和消费消息,去到
./bin
目录下。3.1 打开终端启动消费者。
bash kafka-console-consumer.sh --bootstrap-server XXXX:port --topic XXXX --consumer.config ../config/consumer.properties
说明:
将 XXXX:port 替换成 VPC 网络访问的域名与端口,在控制台实例详情页面的接入方式模块获取。

topic:将 XXXX 替换成 topic 名称,在控制台 topic 管理页面获取。
3.2 另外开一个终端窗口启动生产者。
bash kafka-console-producer.sh --broker-list XXXX:port --topic XXXX --producer.config ../config/producer.properties
说明:
将 XXXX:port 替换成 VPC 网络访问的域名与端口,在控制台实例详情页面的接入方式模块获取。

topic:将 XXXX 替换成 topic 名称,在控制台 topic 管理页面获取。
3.3 输入消息内容之后按回车,即可看到消费端也几乎同时收到消息。
生产消息:


消费消息:

