私はカフカの特定の条件に基づいて消費することができますか？

Question

私はKafkaにmsgを書いて、もう片方でそれを消費しています。 いくつかのプロセスを実行し、別のカフカのトピックに書き戻します。私は応答がどの要求のためにあるメッセージを知りたい

は...

は、現在対応して書き込みと応答ペイロードを読み、同じことを決定し、その後、消費者側からのオフセットIDをキャプチャすることを決定しました。

このアプローチでは、コンシューマ設定条件に基づいて消費できるその他の方法はありますか？

Answer 1

消費者はトピック全体を読むことができます。 seek()を介してのみメッセージをスキップできますが、メッセージをフィルタするためにブローカで評価できる条件はありません。

トピックまたはトピック全体をクライアントで使用する必要があります。