kafka学习笔记03

作者：花生_TL007 | 2024-04-17 19:55:43

踩

kafka学习笔记03

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方法：

添加分区成功

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/花生_TL007/article/detail/441951