消息队列 CKafka 版 运行 Kafka 客户端(可选)

在控制台上完成实例、Topic 等资源配置后,你也可以通过下载并解压 Kafka 工具包,并对 Kafka API 进行简单的收发消息测试。

相关产品
消息队列 CKafka 版 产品页,含版本规格、价格与购买入口。

一、前提条件

·已完成前期的 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

注意:说明:

注意:

3.2 另外开一个终端窗口启动生产者。

bash kafka-console-producer.sh –broker-list XXXX:port –topic XXXX –producer.config ../config/producer.properties

注意:说明:

注意:

3.3 输入消息内容之后按回车,即可看到消费端也几乎同时收到消息。

·生产消息:

·消费消息:

赞 (0)
上一篇 4天前
下一篇 4天前