Spring Kafka - 如何设置 Commit Async 属性

Question

我正在尝试设置允许从 KafkaMessageListenerContainer 调用 commitAsync() 的属性：

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 中配置的引导属性。

您可以覆盖 Boot 的默认 kafkaListenerContainerFactoryConfigurer bean 来执行容器的额外配置。