在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中的消息:
三、接收消息
新开一个terminal窗口,通过kafka-console-consumer 命令行接收topic中的消息。
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
上述输出结果,说明Kafka Server工作正常。
继续在发送消息的terminal窗口,可以再次发送一条信息:
可以在接收消息的terminal窗口,看到新接收到的消息:
访问Kafka技术专栏,了解更多的技术细节和项目代码。
相关推荐
Kafka 2020-09-18
guicaizhou 2020-09-15
jiangkai00 2020-07-18
CobingLiu 2020-06-16
yangyutong00 2020-06-12
sweetgirl0 2020-06-09
guicaizhou 2020-06-12
yanghuashuiyue 2020-11-14
liuxingen 2020-11-13
wangying 2020-11-13
王谦 2020-11-03
huangwei00 2020-10-14
shenzhenzsw 2020-10-09
guicaizhou 2020-09-30
jiaomrswang 2020-09-23
jyj0 2020-09-21
hannuotayouxi 2020-08-20
amwayy 2020-08-03