微信搜索superit|邀请体验:大数据, 数据管理、OLAP分析与可视化平台 | 赞助作者:赞助作者

kafka命令(2.12版本)

kafka aide_941 26℃

创建主题:

./kafka-topics.sh –zookeeper localhost:12181 –create –topic lfwer –partitions 10 –replication-factor 2

 

增加主题分区数

./kafka-topics.sh –zookeeper localhost:12181 –alter –topic lfwer –partitions 10

 

删除主题

在server.properties中增加设置,默认未开启

delete.topic.enable=true

重启kafka

./kafka-server-stop.sh

./kafka-server-start.sh -daemon ../config/server.properties

执行删除

./kafka-topics.sh –zookeeper localhost:12181 –delete –topic lfwer

 

生产数据:

./kafka-console-producer.sh  –topic lfwer –broker-list localhost:9092

 

消费数据:

./kafka-console-consumer.sh –topic lfwer –bootstrap-server localhost:9092

 

查看主题在分区中的偏移量 (time为-1时表示最大值,time为-2时表示最小值)

./kafka-run-class.sh kafka.tools.GetOffsetShell –topic lfwer –time -1 –broker-list localhost:9091 –partitions 0

 

查看有多少个组

./kafka-consumer-groups.sh –bootstrap-server localhost:9091 –list

 

查看组消费情况

./kafka-consumer-groups.sh –bootstrap-server localhost:9091 –describe –group my-group

 

转载请注明:SuperIT » kafka命令(2.12版本)

喜欢 (0)or分享 (0)