操作场景
在控制台上完成实例、Topic 等资源配置后,您也可以通过下载并解压 Kafka 工具包,并对 Kafka API 进行简单的收发消息测试。
前提条件
已完成前期的 CKafka 资源创建。
已参考准备工作完成 Linux 服务器准备和环境配置。 操作步骤
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 输入消息内容之后按回车,即可看到消费端也几乎同时收到消息。
生产消息:
消费消息: