深入解析Kafka启动命令,快速掌握Kafka
Kafka Assistant 是一款可视化监控、管理工具,支持 GPU 渲染和实时监控。它更适合把零散的小功能集中起来使用,处理高频琐碎任务时会更省事。
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





































