kafka下载
下载好,直接解压即可
默认是带有zookeeper(注册中心) 需要先启动zookeeper
zookeeper配置
先配置下zookeeper
这个data文件夹是自定建的 随意建在哪里
注意 这里斜杠用和linux一样
启动zookeeper
进入bin/windows目录 启动zookeeper
zookeeper-server-start.bat ../../config/zookeeper.properties
是安装路径太深了
改下路径即可 另外把zookeeper的dirData路径也改一下
简化zoopeeker启动
为了以后启动zookeeper方便
可以在
把下面代码编辑进去
call bin/windows/zookeeper-server-start.bat config/zookeeper.properties
以后双击就可以了
结果
修改下 用\
call bin\windows\zookeeper-server-start.bat config\zookeeper.properties
kafka配置
下面配置下kafka的配置文件 然后启动
暂时就改个日志存放位置
启动kafka
进入bin/windows
启动命令
kafka-server-start.bat ../../config/server.properties
简化kafka启动
同理
也可以创建一个脚本
call bin\windows\kafka-server-start.bat config\server.properties
相关数据与日志文件
注意关闭顺序
注意启动顺序和关闭顺序
启动时候先启动zookeeper 再启动kafka 关闭时候先关闭kafka 再关闭zookeeper
随便打开一个终端 jps 可以看到zookeeper和kafka已经运行了
终端(命令行Topic主题炒作)
在bin/windows下
D:\kafka\kafka_2.13-3.9.0\bin\windows
有一个 kafka-topics.bat
创建topic
kafka-topics.bat --bootstrap-server localhost:9092 --topic test --create
如图 创建成功
查看所有topic
kafka-topics.bat --bootstrap-server localhost:9092 --list
查看topic详情
kafka-topics.bat --bootstrap-server localhost:9092 --describe
修改topic 分区数量
kafka-topics.bat --bootstrap-server localhost:9092 --topic test --alter --partitions 2
删除topic会出现的问题
删除topic
kafka-topics.bat --bootstrap-server localhost:9092 --topic test --delete
注意 删除topic之后 kafka因权限问题会自动关闭
并且不能再启动kafka
将data里面的zk和kafka都删了 重启 zookeeper和kafka即可
关于临时设置JDK环境问题
kafka最新版本建议用JDK17
如果你现在使用的JDK8 又不想配置环境变量 可以这样
修改bin/windows下的kafka-run-class.bat
需要你下载了jdk 17
命令行中生产者和消费者演示
先创建主题
kafka-topics.bat --bootstrap-server localhost:9092 --topic test --create
启动消费者
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test
启动生产者
kafka-console-producer.bat --bootstrap-server localhost:9092 --topic test
)
)
