KafkaMessageListenerContainerサービスダウン例外がある場合にメッセージを再処理する

Question

外部サービスがダウンした場合にKafkaから消費されたメッセージを失わないように、Spring Kafkaリスナーを設定する必要があります。我々はそれが正常に処理されるまで元に戻したい。

私はこれを達成するために使用できる設定をお手伝いしますか？

メッセージをバッチで消費するにはどうすれば対応できますか。

私たちは、私がRetryが最良のあなたの要件に合うと思いますカフカ0.9

Answer 1

を使用している：

配達、便利なリスナーアダプタ再試行する - RetryingMessageListenerAdapterとRetryingAcknowledgingMessageListenerAdapterをおMessageListenerを使用しているかどうかに応じて、提供されていますまたはAcknowledgingMessageListenerです。