在SpringKafka中，有没有一种方法可以在用户端实现commitsync()？

dz6r00yl 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(278)

在我们的用例中，我们希望在消费者处理消息时立即同步提交。从看http://docs.spring.io/spring-kafka/docs/1.0.0.m2/reference/htmlsingle/ 我看不出用当前版本的api可以做到这一点。
我确实看到了 MANUAL_IMMEDIATE ，但仍然是潜在的 commitAsync() . 是否有同步提交事务的方法？

spring apache-kafka

来源：https://stackoverflow.com/questions/36941080/is-there-way-to-commitsync-in-spring-kafka-on-consumer-side

1条答案

按热度按时间

sqxo8psd1#

你可以用属性 setSyncCommits 论Kafka ListenerContainerFactory .

factory.getContainerProperties().setSyncCommits(true);

赞(0）回复(0）举报 2021-06-07

我来回答

在SpringKafka中，有没有一种方法可以在用户端实现commitsync()？

1条答案

相关问题

热门标签

最新问答