原创

Kafka相关命令操作

温馨提示：

本文最后更新于 2019年03月21日，已超过 2,074 天没有更新。若文章内的图片失效（无法正常加载），请留言反馈或直接联系我。

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

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

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：

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

查看topic的详情：

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

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

所属分类：大数据

本文标签： Kafka
本文链接： http://www.lzhpo.com/article/12
版权声明： 本文由lzhpo原创发布，转载请遵循《署名-非商业性使用-相同方式共享 4.0 国际 (CC BY-NC-SA 4.0)》许可协议授权