一、前提条件
·已完成前期的 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 输入消息内容之后按回车,即可看到消费端也几乎同时收到消息。
·生产消息:
·消费消息: