【问题标题】:Is there way to commitSync() in Spring Kafka on Consumer side?有没有办法在消费者端的 Spring Kafka 中提交同步()?
【发布时间】:2017-12-27 05:21:08
【问题描述】:

在我们的用例中,我们希望在消息由消费者处理后立即同步提交。通过查看http://docs.spring.io/spring-kafka/docs/1.0.0.M2/reference/htmlsingle/,我看不到使用当前版本的 API 执行此操作的方法。

我确实看到有MANUAL_IMMEDIATE,但仍然是其commitAsync() 的底层。有没有同步提交事务的方法?

【问题讨论】:

标签: spring apache-kafka


【解决方案1】:

您可以使用 Kafka ListenerContainerFactory 上的属性 setSyncCommits 来做到这一点。

factory.getContainerProperties().setSyncCommits(true);

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2018-09-12
    • 1970-01-01
    • 2017-09-13
    • 2018-11-23
    • 2021-08-15
    • 2020-11-14
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多