深入解析Kafka启动命令,迅速掌握Kafka
Kafka启动命令详解
1. 启动单个Broker
kafka-server-start.sh 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登录后复制
3. 启动ZooKeeper
zookeeper-server-start.sh config/zookeeper.properties登录后复制
4. 创建Topic
kafka-topics.sh --create --topic test --partitions 3 --replication-factor 2登录后复制
5. 生产数据
kafka-console-producer.sh --topic test登录后复制
6. 消费数据
kafka-console-consumer.sh --topic test --from-beginning登录后复制
7. 停止Kafka
kafka-server-stop.sh登录后复制
8. 停止ZooKeeper
zookeeper-server-stop.sh登录后复制
具体代码示例
以下是一个完整的示例,演示如何启动Kafka集群,创建Topic,生产数据,消费数据,然后停止Kafka集群。
# 启动ZooKeeper zookeeper-server-start.sh config/zookeeper.properties 1. 启动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 1. 创建Topic kafka-topics.sh --create --topic test --partitions 3 --replication-factor 2 1. 生产数据 kafka-console-producer.sh --topic test 1. 消费数据 kafka-console-consumer.sh --topic test --from-beginning 1. 停止Kafka kafka-server-stop.sh 1. 停止ZooKeeper zookeeper-server-stop.sh登录后复制