librdkafka：topic.blacklist configの使い方は？

Question

トピックブラックリスト設定を使用するためのユースケースを理解していませんでした。あなたはそれが使えるときの例を挙げることができますか？ （PS：メタデータ情報の一部のトピックを無視するために使用されていると理解していますが、それがフィルタリングメカニズムのタイプであるかどうか不明です）可能であれば、詳細を教えてください。ありがとう！

Answer 1

トピックが6つあるとします。abc、acd、bcd、test1、test2、test3です。後者の3つを消費する消費者を書く場合、次のように書くことができます。

TopicFilter filter = newブラックリスト（ "a。*、b。*"）;

int threadNumber = xxx;

ストリーム=コネクタ。 createMessageStreamsByFilter（filter、threadNumber）; ...

これは後者の3つのトピックを消費し、以前の3つのトピックを無視します。 正規表現でカンマを使用できる理由は、カフカが '|' OR論理を表現するための符号。