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