Java｜Kotlin, SpringBoot从配置文件中读取@KafkaListener参数配置

• 在java中使用占位符#{'${kakfa.topics}'}来进行参数注入

    @KafkaListener(topics = "#{'${kakfa.topics}'}", groupId = "#{'${kafka.group}'}")
    public void listenGroupFoo(ConsumerRecord record, Acknowledgment ack) throws Exception {
        logger.info("Message received {}", consumerRecord)
        ack.acknowledge();
    }

• 在kotlin中使用占位符${}来进行参数注入

@Component
class Consumer {
    private val logger = LoggerFactory.getLogger(javaClass)

    @KafkaListener(topics = ["${kafka.topics}"], groupId = "${kafka.group}")
    fun listenGroupFoo(consumerRecord: ConsumerRecord, ack: Acknowledgment) {
        logger.info("Message received {}", consumerRecord)
        ack.acknowledge()
    }
}