From e5badd61cd7243c5e116daffdabdadb838f532ec Mon Sep 17 00:00:00 2001 From: Nick Date: Thu, 25 May 2023 10:40:38 +0800 Subject: [PATCH] =?UTF-8?q?kafka=20=E5=91=BD=E4=BB=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- SUMMARY.md | 3 +++ kafka.md | 21 +++++++++++++++++++++ 2 files changed, 24 insertions(+) create mode 100644 kafka.md diff --git a/SUMMARY.md b/SUMMARY.md index e15d993..6eeddc0 100644 --- a/SUMMARY.md +++ b/SUMMARY.md @@ -49,6 +49,9 @@ * [常用配置](used-settings.md) * [编码风格](code-style.md) +## Kafka 命令 +* [Kafka](kafka.md) + ## PHP 依赖工具 * [Composer](composer.md) diff --git a/kafka.md b/kafka.md new file mode 100644 index 0000000..57c92e5 --- /dev/null +++ b/kafka.md @@ -0,0 +1,21 @@ +#### Kafka 命令 + +``` +kafka-topics -bootstrap-server localhost:9092 --create --topic nick --partitions 1 --replication-factor 1 #创建主题命令 + +kafka-topics -bootstrap-server localhost:9092 --delete --topic nick #删除主题命令 + +kafka-topics -bootstrap-server localhost:9092 --list #查看所有主题命令 + +kafka-topics -bootstrap-server localhost:9092 --topic test --describe #查看指定主题详情命令 + +kafka-run-class kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic media-topic --time -1 #查看消息数量 + +kafka-console-producer --broker-list localhost:9092 --topic media-topic #生成数据 + +kafka-console-consumer --topic media-topic --bootstrap-server localhost:9092 #消费者命令 + +kafka-console-consumer --topic media-topic --bootstrap-server localhost:9092 --from-beginning #消费者命令 --from-beginning 表示从最初的未过期的 offset 处开始消费数据。不加该参数,表示从最新 offset 处开始消费数据。 + +kafka-consumer-groups --bootstrap-server localhost:9092 --list #查看消费组 +``` \ No newline at end of file