カフカからメッセージを取得し、それらをいくつかのデータにラップして外部サービスに送信する単純なサービスを実装しようとしています。
メッセージを処理するときに外部サービスが利用できない場合の一般的なパターンは何ですか?
これまでのところ、外部サービスへのリクエストが成功した場合にのみ、メッセージを手動でコミットしています。外部サービスの失敗の処理が消費者に透過的になるように、コミットされていない場合、しばらくしてからカフカにメッセージを再送信してもらいたいと思います。私はそれを行う方法を見つけることができませんでした。ただし、アンチパターンを行っていない場合は興味があり、より良い解決策があります。