在Spring Kafka中设置isolation.level = read_committed(Spring Boot version 1.5.18 and spring Kafka version 1.3.8)

Set isolation.level = read_committed in Spring Kafka (Spring Boot version 1.5.18 and spring Kafka version 1.3.8)

我正在使用 spring 链式横断管理器设置 kafka 横断管理器,我必须在 Spring Kafka 中设置 isolation.level = read_committed(Spring 作为消费者启动版本 1.5.18 和 spring Kafka 版本 1.3.8) 属性 但找不到任何设置方法。

不要在多个地方问同一个问题;这是浪费你和我们的时间。

the boot documentation

在 1.5 中,有一个通用全局 properties 属性,您可以在其中设置任意属性(2.0 和更高版本分别为消费者和生产者添加了通用 properties)。

spring.kafka.properties.isolation.level=read_committed