Невозможно установить для autoCommitOffset значение true, используя потоки облачной кафки

Kurshit спросил: 11 марта 2019 в 07:29 в: spring-boot

Я использую Spring-Cloud-Starter-Stream-Kafka - 1.3.3 и Spring-Cloud-Stream с Spring Boot для подключения к Kafka, который состоит из типичного сценария использования подписчика Publisher, в котором я хочу, чтобы enable.auto.commit быть правдой.

Когда служба запускается, я вижу несколько свойств Kafka (журналов INFO), печатаемых на консоли, где перечислены все примененные свойства. Я вижу значение этого свойства как false- enable.auto.commit = false, как показано ниже:

auto.commit.interval.ms = 100
enable.auto.commit = false
auto.offset.reset = earliest
check.crcs = true
client.id = consumer-2
connections.max.idle.ms = 540000
    exclude.internal.topics = true
fetch.max.bytes = 52428800
fetch.max.wait.ms = 500
fetch.min.bytes = 1
group.id = conn-dr-group
heartbeat.interval.ms = 3000

я читал в Spring Doc, что если мы не предоставим свойство автоматическая фиксация, по умолчанию она имеет значение -

https://docs.spring.io/autorepo/docs/spring-cloud-stream-binder-kafka-docs/1.1.0.M1/reference / htmlsingle /

Однако при загрузке службы значение все равно кажется ложным.

Я попытался указать следующее свойство в application.properties, но все равно оно принимает значение false.

spring.cloud.stream.kafka.bindings.input.autoCommitOffset = true

Кто-нибудь знает, как мы можем получить значение true?

0 ответов