原创

Kafka相关命令操作

启动/停止Kafka

#启动Kafka
kafka-server-start.sh config/server.properties &

#停止Kafka
kafka-server-stop.sh stop

topic相关命令

创建topic

kafka-topics.sh --zookeeper localhost:2181 --create --replication-factor 1 --partitions 1 --topic first

--topic 定义topic名
--replication-factor 定义副本数
--partitions 定义分区数

不能超过设置的topic在当前broker上的分区个数
我设置的是num.partitions=1

查看topic

列出服务器中的topic:

kafka-topics.sh --zookeeper localhost:2181 --list

查看topic的详情:

kafka-topics.sh --zookeeper localhost:2181 --describe --topic first

删除topic

kafka-topics.sh --zookeeper localhost:2181 --delete --topic first

需要server.properties中设置delete.topic.enable=true否则只是标记删除或者直接重启。

开启生产者

kafka-console-producer.sh --broker-list localhost:9092 --topic first

开启消费者

kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic first

--from-beginning:会把first主题中以往所有的数据都读取出来。根据业务场景选择是否增加该配置。

正文到此结束