生产用的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名就可以了


Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐