springboot 多topic 动态配置

项目中需要能够动态配置topic进行消费。

1.application.properties中配置topicName=topic1,topic2

2.@KafkaListener(topics = {"#{'${topicName}'.split(',')}"})

3.pom文件引入springkafka-1.2.2，不能引入springkafka-1.1.0。

原因如下:

1.1.0中的resolveAsString方法有bug，缺少1个else，当传入数组时，这个方法一定会抛出异常.

这个bug在1.2.2中已修复。

1.1.0如下所示:

1.2.2如下所示:

springboot 多topic 动态配置相关推荐

springboot集成Appollo动态配置
pom新增依赖:  ...
SpringBoot数据库密码动态配置
一般的开发,我们都习惯把数据库密码配置在属性文件中,这样配置方便好用,但是缺点也是很明显的.这样配置的密码是静态的.明文的.一般都安全要求比较严格的公司,这些密码都会被统一管理,定期修改.我们需要动态 ...
kafka原理_Kafka动态配置实现原理解析
总第19篇 2019年第15篇一.问题导读Apache Kafka在全球各个领域各大公司获得广泛使用,得益于它强大的功能和不断完善的生态.其中Kafka动态配置是一个比较高频好用的功能,下面我们 ...
【kafka】Kafka中的动态配置源码分析
1.概述 2.源码分析 Broker启动加载动态配置 KafkaServer.startup 启动加载动态配置总流程 2.1 动态配置初始化 config.dynamicConfig.initiali ...
springboot整合Quartz实现动态配置定时任务
版权声明:本文为博主原创文章,转载请注明出处. https://blog.csdn.net/liuchuanhong1/article/details/60873295 前言在我们日常的开发中,很多 ...
SpringBoot打成jra包启动时读取外部配置文件实现动态配置
场景若依前后端分离版手把手教你本地搭建环境并运行项目: https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/108465662 在上面 ...
SpringBoot 优雅实现动态数据源切换配置
点击关注公众号,利用碎片时间学习前言随着应用用户数量的增加,相应的并发请求的数量也会跟着不断增加,慢慢地,单个数据库已经没有办法满足我们频繁的数据库操作请求了,在某些场景下,我们可能会需要配置多个 ...
maven springboot 除去指定的jar包_Spring Boot打包瘦身 Docker 使用全过程动态配置、日志记录配置...
springBoot打包的时候代码和jar包打包在同一个jar包里面,会导致jar包非常庞大,在不能连接内网的时候调试代码,每次只改动了java代码就需要把所有的jar包一起上传,导致传输文件浪费了很 ...
SpringBoot 动态配置邮箱发件人
SpringBoot 动态配置邮箱发件人现在的消息模块少不了邮件发送.短信发送和手机推送的功能.邮件发送的功能历史最为悠久,也算的上烂大街的功能.一般在配置文件中设置好邮箱地址.账号.密码和发件服务 ...
kafka动态配置topic
之前使用@org.springframework.kafka.annotation.KafkaListener这个注解的时候,是在yml文件中配置,然后使用@KafkaListener(topics ...

springboot 多topic 动态配置

springboot 多topic 动态配置相关推荐

最新文章

热门文章