【spring-kafka】使用SPEL表达式为消费者配置topic

it2025-02-25  29

1、KafkaListener

spring-kafka确实很方便,在方法上加@KafkaListener便实现对kafka数据的接收。从KafkaListener这个注解的各个参数注释上我们可以看出,各个参数不仅可以配置直接的值,也可以配置SPEL表达式,还是比较灵活的。

2、topic配置的几种方式

(1)直接设置为字符常量,不再赘述 (2)application.properties中配置topic topics配置为#{’${target.topic}’.split(’,’)} (3) 通过调用方法动态设置topic 定义一个管理topic的bean

@Component public class TopicHandler { public String getTopics(){ return "test_topic_1,test_topic_2"; } }

topics设置为#{topicHandler.getTopics().split(’,’)}

最新回复(0)