怎么在社保网站上做员工减少,南京招投标中心官网,企信网官网登录入口北京,seo刷词SpringBoot2.X项目搭建整合Kafka客户端依赖配置 用自己对应的jdk版本。 先加上我们的web依赖。
添加kafka依赖: SpringBoot2.x整合Kafka客户端adminApi单元测试 设置端口号。
新建一个kafka测试类#xff1a; 创建一个初始化的Kafka服务。 设置kafka的名称。 测试创建kafka。…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方法
