原创

Kafka相关命令操作

温馨提示:
本文最后更新于 2019年03月21日,已超过 1,859 天没有更新。若文章内的图片失效(无法正常加载),请留言反馈或直接联系我

启动/停止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主题中以往所有的数据都读取出来。根据业务场景选择是否增加该配置。

本文目录