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