有沒有辦法在消費者一方的春季卡夫卡commitSync（）？

Question

在我們的用例中，我們希望在消費者進行消息後立即同步提交。從查看http://docs.spring.io/spring-kafka/docs/1.0.0.M2/reference/htmlsingle/我看不到用當前版本的API執行此操作的方法。

我確實看到有MANUAL_IMMEDIATE，但仍然是其基礎的commitAsync()。有沒有同步提交交易的方法？

Answer 1

您可以使用卡夫卡ListenerContainerFactory上的屬性setSyncCommits來做到這一點。

factory.getContainerProperties().setSyncCommits(true);