windows上操作kafka的常用命令-topic的增删改查
生产用的kafka都是在linux上搭建集群,为了在本地快速学习kafka,可以搭建一个单机版的windows环境,我下载的是0.9版本安装很简单,基本就是下载之后解压就可以了,但是在安装kafka之前要先安装zookeeper,单机版的zookeeper也很好安装,下载之后解压就可以了试验时要启动zookeeper,然后再启动kafka下面是windows cmd操作kafka的常用命令进入ka
生产用的kafka都是在linux上搭建集群,为了在本地快速学习kafka,可以搭建一个单机版的windows环境,我下载的是0.9版本
安装很简单,基本就是下载之后解压就可以了,但是在安装kafka之前要先安装zookeeper,
单机版的zookeeper也很好安装,下载之后解压就可以了
试验时要启动zookeeper,然后再启动kafka
下面是windows cmd操作kafka的常用命令
进入kafka目录下,不用进入bin目录下
--创建topic,如果只有一台broker,最后一个复本个数只能为1
.\bin\windows\kafka-topics.bat --zookeeper localhost:2181 --create --topic delivery --partitions 16 --replication-factor 1
-- 查看所有topic
.\bin\windows\kafka-topics.bat --zookeeper localhost:2181 --list
-- 查看指定topic信息
.\bin\windows\kafka-topics.bat --zookeeper localhost:2181 --describe --topic luoluo
-- 查看topic某分区偏移量最大(小)值
.\bin\windows\kafka-run-class.bat kafka.tools.GetOffsetShell --topic luoluo --time -1 --broker-list localhost:9092 --partitions 0
-- 删除topic,慎用,只会删除zookeeper中的元数据,消息文件须手动删除
.\bin\windows\kafka-topics.bat kafka.admin.DeleteTopicCommand --zookeeper localhost:2181 --delete --topic linlin
这是创建一个有16个分区的topic,然后使用describe查看这个topic的详细信息
-- 这是执行.\bin\windows\kafka-topics.bat的可选参数
Command must include exactly one action: --list, --describe, --create, --alter or --delete
--alter Alter the number of partitions,replica assignment, and/or configuration for the topic.
其实这组命令特别好用,前面统一都是.\bin\windows\kafka-topics.bat --zookeeper localhost:2181
如果要查所有topic : --list
如果要看某个topic:--describe --topic taotao
如果要删除某个topic: --delete --topic taotao
总之只要先指定你要做的动作,列表 删除 描述
第二个参数指定topic名就可以了
更多推荐
所有评论(0)