SpringBoot中@KafkaListener使用${}动态指定topic问题

 更新时间:2024年12月12日 14:22:47   作者:涛哥是个大帅比  
在SpringKafka中,使用${}引用Spring属性配置,可以在不同环境中重新配置topic名称,而无需修改代码,在application.properties或application.yml中定义topic名称,并在代码中使用${}引用

项目场景

在Spring Kafka中,我们可以使用${}来引用Spring的属性配置。

这样我们就可以在不同的环境中重新配置topic名称,而不需要修改代码。

解决方案

  • 在application.properties或application.yml中定义topic名称:
# application.properties
kafka.topic=myTopic
  • 然后在你的代码中使用${}来引用这个属性:
@KafkaListener(topics = "${kafka.topic}")
public void listen(String message) {
    System.out.println("Received message in topic : " + message);
}
  • 如果你使用的是多个topic
  • 你可以使用;来分割多个topic名称:
# application.properties
kafka.topics=topic1;topic2;topic3
  • 然后在你的代码中使用${}来引用这个属性:
@KafkaListener(topics = "${kafka.topics}")
public void listen(String message) {
    System.out.println("Received message in topic : " + message);
}

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • 简单工厂模式_动力节点Java学院整理

    简单工厂模式_动力节点Java学院整理

    这篇文章主要介绍了简单工厂模式的相关资料,和大家一起学习静态工厂方法模式,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-08-08
  • springboot使用nacos的示例详解

    springboot使用nacos的示例详解

    这篇文章主要介绍了springboot使用nacos的示例代码,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2021-12-12
  • springboot实现配置多个yml文件

    springboot实现配置多个yml文件

    文章主要介绍了在Spring Boot项目中实现多环境配置的三种方式:方式一、多YAML文件配置;方式二、单YAML文件配置;方式三、在pom.xml中指定环境配置,每种方式都有其特点和适用场景
    2025-11-11
  • Java并发编程之同步容器

    Java并发编程之同步容器

    这篇文章主要介绍了Java并发编程之同步容器,文中有非常详细的代码示例,对正在学习java的小伙伴们有很好的帮助,需要的朋友可以参考下
    2021-05-05
  • java之向linux文件夹下写文件无权限的问题

    java之向linux文件夹下写文件无权限的问题

    这篇文章主要介绍了java之向linux文件夹下写文件无权限的问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-09-09
  • Java手动配置线程池过程详解

    Java手动配置线程池过程详解

    这篇文章主要介绍了Java手动配置线程池过程详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-05-05
  • Java单链表基本操作的实现

    Java单链表基本操作的实现

    链表是一种数据结构,和数组同级。接下来通过本文给大家介绍Java单链表基本操作的实现,非常不错,具有参考借鉴价值,感兴趣的朋友一起看下吧
    2016-07-07
  • JVM性能调优实现原理及配置

    JVM性能调优实现原理及配置

    这篇文章主要介绍了JVM性能调优实现原理及配置,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-12-12
  • 详解在Spring Boot框架下使用WebSocket实现消息推送

    详解在Spring Boot框架下使用WebSocket实现消息推送

    这篇文章主要介绍了详解在Spring Boot框架下使用WebSocket实现消息推送,具有一定的参考价值,感兴趣的小伙伴们可以参考一下。
    2016-12-12
  • java为什么不建议用equals判断对象相等

    java为什么不建议用equals判断对象相等

    本文主要介绍了java为什么不建议用equals判断对象相等,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-03-03

最新评论