在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) 属性 但找不到任何设置方法。
不要在多个地方问同一个问题;这是浪费你和我们的时间。
在 1.5 中,有一个通用全局 properties
属性,您可以在其中设置任意属性(2.0 和更高版本分别为消费者和生产者添加了通用 properties
)。
spring.kafka.properties.isolation.level=read_committed
我正在使用 spring 链式横断管理器设置 kafka 横断管理器,我必须在 Spring Kafka 中设置 isolation.level = read_committed(Spring 作为消费者启动版本 1.5.18 和 spring Kafka 版本 1.3.8) 属性 但找不到任何设置方法。
不要在多个地方问同一个问题;这是浪费你和我们的时间。
在 1.5 中,有一个通用全局 properties
属性,您可以在其中设置任意属性(2.0 和更高版本分别为消费者和生产者添加了通用 properties
)。
spring.kafka.properties.isolation.level=read_committed