深入解析Kafka启动命令,迅速掌握Kafka

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登录后复制