Kafka 命令行操作

本文主要是介绍Kafka 命令行操作，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

创建主题

bin/kafka-topics.sh --create --zookeeper centos01:2181,centos02:2181,centos03:2181 --replication-factor 2 --partitions 2 --topic topictest

输出Created topic "topictest".则说明主题topictest创建成功：

此时查看ZooKeeper中Kafka创建的/brokers节点，发现topictest的信息已记录在其中：

查询主题

bin/kafka-topics.sh --list --zookeeper centos01:2181

bin/kafka-topics.sh --describe --zookeeper centos01:2181

创建生产者

bin/kafka-console-producer.sh --broker-list centos01:9092,centos02:9092,centos03:9092 --topic topictest

创建完成后，控制台进入等待键盘输入消息的状态：

创建消费者

bin/kafka-console-consumer.sh --bootstrap-server centos01:9092,centos02:9092,centos03:9092 --topic topictest

消费者创建成功后，就等待生产者发送消息：

此时生产者发送消息后消费者就可以接收了：

这篇关于Kafka 命令行操作的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！