深入解析Kafka启动命令,快速掌握Kafka
作者:WarmHope
时间:2024-02-01
浏览:0
Kafka启动命令详解1.启动单个Brokerkafka-server-start.shconfig/server.properties该命令将启动一个KafkaBroker,并使用config/server.properties作为配置文件。2.启动多个Brokerkafka-server-start.shconfig/server-1.prop
Kafka启动命令详解
1. 启动单个Broker
kafka-server-start.sh config/server.properties
该命令将启动一个Kafka Broker,并使用config/server.properties作为配置文件。
2. 启动多个Broker
kafka-server-start.sh config/server-1.properties kafka-server-start.sh config/server-2.properties kafka-server-start.sh config/server-3.properties
该命令将启动三个Kafka Broker,并使用config/server-1.properties、config/server-2.properties和config/server-3.properties作为配置文件。
3. 启动ZooKeeper
zookeeper-server-start.sh config/zookeeper.properties
该命令将启动一个ZooKeeper服务器,并使用config/zookeeper.properties作为配置文件。
4. 创建Topic
kafka-topics.sh --create --topic test --partitions 3 --replication-factor 2
该命令将创建一个名为test的Topic,该Topic具有3个分区和2个副本因子。
5. 生产数据
kafka-console-producer.sh --topic test
该命令将启动一个控制台生产者,该生产者将数据发送到test Topic。
6. 消费数据
kafka-console-consumer.sh --topic test --from-beginning
该命令将启动一个控制台消费者,该消费者将从test Topic的开头开始消费数据。
7. 停止Kafka
kafka-server-stop.sh
该命令将停止所有正在运行的Kafka Broker。
8. 停止ZooKeeper
zookeeper-server-stop.sh
该命令将停止ZooKeeper服务器。
具体代码示例
以下是一个完整的示例,演示如何启动Kafka集群,创建Topic,生产数据,消费数据,然后停止Kafka集群。
# 启动ZooKeeper zookeeper-server-start.sh config/zookeeper.properties # 启动Kafka Broker kafka-server-start.sh config/server-1.properties kafka-server-start.sh config/server-2.properties kafka-server-start.sh config/server-3.properties # 创建Topic kafka-topics.sh --create --topic test --partitions 3 --replication-factor 2 # 生产数据 kafka-console-producer.sh --topic test # 消费数据 kafka-console-consumer.sh --topic test --from-beginning # 停止Kafka kafka-server-stop.sh # 停止ZooKeeper zookeeper-server-stop.sh
注意事项
作者最新文章
Photoshop图层阵列怎么做?复制多个图层并整齐排列
2026-09-22 16:42
3dmax动画技巧总结:动画制作步骤与渲染视频教程
2026-09-22 14:47
思源笔记
2026-09-16 17:42
在线PDF转TXT操作步骤与乱码排查指南
2026-09-04 13:02
PDF加水印后如何检查显示效果?在线工具操作步骤与避坑指南
2026-09-03 13:02
上一篇:
彩虹火神4090的售价多少?
热门文章
更多
精品专题
更多
Mac软件
更多
WINDOWS
更多


































