私たちはKafka Consumerによって特定のキー付きメッセージを聞くことができます

Question

私はKafkaを非常に新しくしています。私はいくつかの特定のメッセージだけを読む必要があるという要件があります。

このため、私はカフカにメッセージをいくつかのキーと値でプッシュします。特定のキーのリストに消費者を登録する方法はありますか？メッセージがKafkaにプッシュされたとき、消費者はメッセージに消費者が聞いているキーがあるかどうかを知るため消費者が消費することになります。

Answer 1

私が考えることができる唯一の方法は、パブリッシャーが関心のあるキーでメッセージを送信するパーティションにコンシューマーを割り当てることができることです。また、独自のパーティショナーを作成する必要があります。キーXを持つメッセージを常に同じパーティションに送ります。

簡単な方法：必要なメッセージだけを処理する方法でコンシューマーを作成します。