如何设置提交异步属性

l0oc07j2  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(392)

我正在尝试设置允许从kafkamessagelistenercontainer调用commitasync()的属性:

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

有没有办法在我的application.yml文件中设置这个?我可以将ack mode设置为batch,但是我找不到将容器属性synccommits设置为false的方法。

uyto3xhc

uyto3xhc1#

该属性当前未公开为可在yaml中配置的引导属性。
您可以覆盖引导的默认设置 kafkaListenerContainerFactoryConfigurer bean来执行容器的附加配置。

相关问题