コンシューマーグループのオフセットが別のグループのオフセットより遅いことを確認してください

私はカフカのトピックからAとBの2つのサービスを処理しています。しかし、Bは、Aがそうすることを終える前に、トピックからのものを処理してはならない。 Bのpoll()がAによってコミットされたレコードのみを返すようにする方法はありますか？コンシューマーグループのオフセットが別のグループのオフセットより遅いことを確認してください

この場合、パイプラインを作成し、AによってコミットされたメッセージをBが購読する新しいトピックにプッシュする必要があります。

2017-12-07 09:21:27 Abhimanyu

この場合、メッセージを新しいトピックにプッシュするために注意を払わなければならないのはそれ自身ですか？あるいは、「Aがメッセージをコミットし、自動的にトピックXにプッシュする」とカフカに伝えることは可能ですか？ –

@AntonisChristofidesあなたはトピックにメッセージをプッシュするためにkafkaProducer.sendコマンドを書く必要があります。私はあなたがパイプラインを作っているという単純な言葉です。 – Abhimanyu

=> 0.11をカフカで取引を行うことの詳細をチェックアウト：https://www.confluent.io/blog/transactions-apache-kafka/

しかし、あなたが実際に多分（@Abhimanyuが示唆するように）を消費するためにBのために戻って別のトピックへの農産物を持つ、構築しているものに応じてここでは正しいオプションかもしれません。

2017-12-07 13:36:56

答えて