在Mac中演示最新版Kafka v2.3.1 消息的发送和接收

上一章中,我们介绍了在Mac上安装、启动最新版Apache Kafka v2.3.1。本文将继续演示在Mac 中Kafka Server的使用。

在开始下面的步骤之前,首先需要启动Apache Kafka server。

一、创建Topic

打开一个terminal窗口,在kafka 安装目录,执行如下命令。

# 创建topic

rickie@192 kafka_2.12-2.3.1 % bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

# 查看创建的topic

rickie@192 kafka_2.12-2.3.1 % bin/kafka-topics.sh --list --bootstrap-server localhost:9092

test

二、发送消息

通过kafka安装包提供了kafka-console-producer 命令行工具发送消息到前面创建的topic中。

# 发送消息

rickie@192 kafka_2.12-2.3.1 % bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

>hello world

>nice to meet you.

>

可以通过kafka 技术专栏中介绍过的Kafka Tool 2 可视化工具,查看topic中的消息:

在Mac中演示最新版Kafka v2.3.1 消息的发送和接收

三、接收消息

新开一个terminal窗口,通过kafka-console-consumer 命令行接收topic中的消息。

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

在Mac中演示最新版Kafka v2.3.1 消息的发送和接收

上述输出结果,说明Kafka Server工作正常。

继续在发送消息的terminal窗口,可以再次发送一条信息:

在Mac中演示最新版Kafka v2.3.1 消息的发送和接收

可以在接收消息的terminal窗口,看到新接收到的消息:

在Mac中演示最新版Kafka v2.3.1 消息的发送和接收

访问Kafka技术专栏,了解更多的技术细节和项目代码。

相关推荐