@KafkaListener
从2.2.4版开始,您可以直接在注释上指定Kafka使用者属性,这些属性将覆盖在使用者工厂中配置的具有相同名称的所有属性。
可以使用#{…}或属性占位符(${…})在SpEL上配置注释上的大多数属性。
例如:
@KafkaListener(id = "consumer-id",
topics = "SHI_TOPIC1",
concurrency = "${listen.concurrency:3}",
clientIdPrefix = "myClientId")
属性
id : 消费者id
topics :监听的主题, 多个逗号隔开
concurrency:
clientIdPrefix:
errorHandler
标签:简介,topics,KafkaListener,concurrency,clientIdPrefix,id,属性 From: https://www.cnblogs.com/qds1401744017/p/17083566.html