Spring Kafka - Как установить свойство Commit Async

Question

Я пытаюсь установить свойство, позволяющее вызывать commitAsync() из KafkaMessageListenerContainer:

if (this.containerProperties.isSyncCommits()) {
    this.consumer.commitSync(commits);
}
else {
    this.consumer.commitAsync(commits, is.commitCallback);
}

Есть ли способ установить это в моем файле application.yml? Мне удалось установить ack-mode на BATCH, но я не могу найти способ установить для свойства контейнера значение syncCommits, равное false.

Answer 1

Это свойство в настоящее время не отображается как загрузочное свойство, которое можно настроить в YAML.

Вы можете отменить загрузку по умолчанию kafkaListenerContainerFactoryConfigurer Боб для выполнения дополнительной настройки контейнеров.