JZTXT

@KafkaListener属性简介

发布时间 2023-04-27 16:30:35作者: 一贯可乐

@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