Springboot中使用kafka

首先说明，本人之前没用过zookeeper、kafka等，尚硅谷十几个小时的教程实在没有耐心看，现在我也不知道分区、副本之类的概念。用kafka只是听说他比RabbitMQ快，我也是昨天晚上刚使用，下文中若有讲错的地方或者我的理解与它的本质有偏差的地方请包涵。
此文背景的环境是windows，linux流程也差不多。

官网下载kafka，选择Binary downloads Apache Kafka

解压在D盘下或者什么地方，注意不要放在桌面等绝对路径太长的地方

打开config中的 zookeeper.properties，自己选择性修改clientPort，不想改也行

修改config中的 server.properties

1.取消 advertised.listeners 注释，修改kafka地址与端口。如果要集群部署，broker.id不能重复，1号机是0，2号机是1这样的。
2.修改 zookeeper.connect 为你上面zookeeper.properties中配置的地址

配置好了，尝试开启kafka 。

来到bin/windows，shift右键在此处打开cmd，输入 zookeeper-server-start.bat ../../config/zookeeper.properties，等待其启动。(注意你config的路径不要写错)
启动完再开一个cmd，输入 kafka-server-start.bat ../../config/server.properties 。
如果在此环节出现问题，请查看logs中的日志，面向csdn 。
我遇到的问题是他显示什么什么路径太长了，问题的原因是我把他放桌面上了。

新建springboot项目，pom中添加依赖

org.springframework.bootspring-boot-starter-weborg.springframework.kafkaspring-kafkaorg.projectlomboklomboktruecom.alibabafastjson1.2.28

配置application.yml，写启动类，controller，创建User类，创建consumer