我们可以在@KafkaListener( property Can = {max.pool.size.ms: ternary operator )中添加动态属性吗

Question

@KafkaListener可以有动态三值条件吗？

Answer 1

可以；参见this test case。

@KafkaListener(id = "#{'qux'}", topics = "annotated4",
        containerFactory = "kafkaManualAckListenerContainerFactory", containerGroup = "qux#{'Group'}",
        properties = {
                "max.poll.interval.ms:#{'${poll.interval:60000}'}",
                ConsumerConfig.MAX_POLL_RECORDS_CONFIG + "=#{'${poll.recs:100}'}"
        })

在这种情况下，它将加载poll.interval属性，如果缺少该属性，则使用60000。

您可以使用任何SpEL表达式，例如

#{@someBean.someProperty}

#{'${foo.prop}' == null ? '${bar.prop:60000}' : '${foo.prop}'