Linux——kafka常用命令-Toy模板网

这篇具有很好参考价值的文章主要介绍了Linux——kafka常用命令。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

一、前言

多多点赞，会变好看！

多多留言，会变有钱！

二、Kafka的常用命令包括：

1. 启动Zookeeper服务

前台启动：

./bin/zookeeper-server-start.sh config/zookeeper.properties

后台启动：

./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

2. 停止Zookeeper服务

./bin/zookeeper-server-stop.sh

3. 启动Kafka服务

前台启动：

./bin/kafka-server-start.sh config/server.properties

后台启动：

./bin/kafka-server-start.sh -daemon config/server.properties

4. 停止Kafka服务

./bin/kafka-server-stop.sh

5. 创建主题

创建一个叫demo-topic的主题（topic)，有两个分区，每个分区3个副本，同时指定该主题的消息保留时长（72小时）：

./bin/kafka-topics.sh --zookeeper(host:port) --create --topic demo-topic --replication-factor 3 --partitions 2 --topic test --retention-hours 72

单机创建主题

bin/kafka-topics.sh --create --replication-factor 1 --partitions 1 --topic test --bootstrap-server localhost:9092

6. 查看所有主题

./bin/kafka-topics.sh --list --bootstrap-server localhost:9092

7. 生产消息

./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

8. 消费消息

./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

没有zookeeper：

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

9. 查看某一topic具体信息：

./bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test

没有zookeeper：文章来源地址https://www.toymoban.com/news/detail-770650.html

./bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test

三、组合启动/停止

启动服务

#/bin/bash
#启动zookeeper
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

#启动kafka
bin/kafka-server-start.sh -daemon config/server.properties

停止服务

#/bin/bash
#停止zookeeper
bin/kafka-server-stop.sh
#停止kafka
bin/zookeeper-server-stop.sh

到了这里，关于Linux——kafka常用命令的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

Linux——kafka常用命令