コンシューマ側のSpring KafkaでcommitSync（）メソッドがありますか？

Question

私たちのユースケースでは、メッセージがコンシューマによって処理されるとすぐに同期コミットします。 http://docs.spring.io/spring-kafka/docs/1.0.0.M2/reference/htmlsingle/を見ると、現在のバージョンのAPIでこれを行う方法はありません。

MANUAL_IMMEDIATEが表示されていますが、依然としてその基礎となるcommitAsync()があります。トランザクションを同期的にコミットする方法はありますか？

Answer 1

これは、Kafka ListenerContainerFactoryのプロパティsetSyncCommitsを使用して行うことができます。

factory.getContainerProperties().setSyncCommits(true);