SpringBoot2.X项目搭建整合Kafka客户端依赖配置
用自己对应的jdk版本。
先加上我们的web依赖。
添加kafka依赖:
SpringBoot2.x整合Kafka客户端+adminApi单元测试
设置端口号。
新建一个kafka测试类：
创建一个初始化的Kafka服务。
设置kafka的名称。
测试创建kafka。
控制台会返回很多信息。
我们看到了我们刚才创建的kafka。
我们在linux上查看一下当前kafka的分区和副本数量:
Kafka使用JavaAPI-AdminClient创建和列举topic
我们创建的topic都会返回。但是不能返回内部的topic。
所以我们再去改写：
接下来我们来学习删除topic的api方法：
