kafka-server-start.sh config/server.properties
该命令将启动一个Kafka Broker,并使用config/server.properties
作为配置文件。config/server.properties
作为配置文件。
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
作为配置文件。
zookeeper-server-start.sh config/zookeeper.properties
该命令将启动一个ZooKeeper服务器,并使用config/zookeeper.properties
作为配置文件。
kafka-topics.sh --create --topic test --partitions 3 --replication-factor 2
该命令将创建一个名为test
的Topic,该Topic具有3个分区和2个副本因子。
kafka-console-producer.sh --topic test
该命令将启动一个控制台生产者,该生产者将数据发送到test
Topic。
kafka-console-consumer.sh --topic test --from-beginning
该命令将启动一个控制台消费者,该消费者将从test
kafka-server-stop.sh
config/server-1.properties
、config/server-2.properties
和config/server-3.properties
作为配置文件。3. 启动ZooKeeperzookeeper-server-stop.sh
config/zookeeper.properties
作为配置文件。4. 创建Topic# 启动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
test
的Topic,该Topic具有3个分区和2个副本因子。test
Topic。test
Topic的开头开始消费数据。以上是深入解析Kafka启动命令,迅速掌握Kafka的详细内容。更多信息请关注PHP中文网其他相关文章!