我正在尝试设置允许从kafkamessagelistenercontainer调用commitasync()的属性:
if (this.containerProperties.isSyncCommits()) {
this.consumer.commitSync(commits);
}
else {
this.consumer.commitAsync(commits, is.commitCallback);
}
有没有办法在我的application.yml文件中设置这个?我可以将ack mode设置为batch,但是我找不到将容器属性synccommits设置为false的方法。
1条答案
按热度按时间uyto3xhc1#
该属性当前未公开为可在yaml中配置的引导属性。
您可以覆盖引导的默认设置
kafkaListenerContainerFactoryConfigurer
bean来执行容器的附加配置。