如何在属性文件 spring boot 中设置 Acks=all

Question

我想在我的 spring cloud stream kafka 应用程序中为我的生产者设置 acks=all 属性。

我试过这样：

spring.cloud.stream.kafka.binder.requiredAcks=all

和

spring.cloud.stream.kafka.streams.binder.configuration=all

和

spring.cloud.stream.kafka.streams.bindings.<channel>.producer.configuration.requiredAcks=all

不幸的是，注意到对我有用。

您能否帮我将这些属性设置为应用程序级别或生产者/消费者。

Answer 1

以下配置仅由 Kafka Binder 使用（不是 kafka Streams 之一）。用于设置生产者实例的acks属性。

spring.cloud.stream.kafka.binder.requiredAcks

要配置 Kafka Streams 实例，属性必须以 spring.cloud.stream.kafka.streams.binder(Spring Cloud Stream Configuration).

在 KafkaStreams 中，可以通过添加前缀“.producer”来覆盖生产者属性（请参阅Configuring a Streams Application；因此要配置生产者确认，您应该定义以下属性：

spring.cloud.stream.kafka.streams.binder.configuration.producer.acks=all

请注意，如果您正在构建有状态的 Kafka Streams 应用程序，强烈建议启用 exactly_once 语义。

这个语义可以配置为：

spring.cloud.stream.kafka.streams.binder.configuration.processing.guarantee=exactly-once