セレクタ付きApache Kafkaクライアント？

Question

私はApache Kafkaを調査中です。私の使用事例では、クライアントがメッセージをフィルタリングできることが必要であり、フィルタリングはクライアントではなくブローカで行われることが必要です。この要件は、JMSセレクタの使用と同じです。

私は多分間違っていますが、カフカにはセレクタがなく、そのフィルタリングがクライアント上で行われていることを理解しています。したがって、すべてのメッセージはクライアントに送信され、クライアントはフィルタを担当します。

フィルタリングがブローカ上で行われるJMSセレクタアプローチを実現する方法はありますか？

Answer 1

いいえ、そんなことはできません。あなたができることは、クライアント側でフィルタリングすることです。 Apache Kafka APIは、「オフセットXから始まるトピックNパーティションMに対して最大1メガバイトのメッセージを与えます」という種類のフェッチのみをサポートしています。

Wire Protocol referenceを参照すると、フェッチ要求のオプションが表示されますが、探しているものはありません。

実際には、すべてのフェッチがシーケンシャルな読み込みであるため、Kafkaは高速です。したがって、これは将来のリリースでは実装されないと思いますが（私が間違っていると嬉しいです:)）。