0
私は消費者に複数のトピックを購読しているとします。 投票すると、どのトピックが選ばれますか? 私はクライアントにRdKafka .Netを使用しています。私が影響を与えることができる方法はありますか、どのトピックが選択されていますか?カフカの消費者は、どのトピックから次に投票するのですか?
私は消費者に複数のトピックを購読しているとします。 投票すると、どのトピックが選ばれますか? 私はクライアントにRdKafka .Netを使用しています。私が影響を与えることができる方法はありますか、どのトピックが選択されていますか?カフカの消費者は、どのトピックから次に投票するのですか?
コンシューマは、(一時停止されていない)すべてのトピックパーティションをポーリングします。ブローカは、返すデータを決定します。ブローカーの行動に直接影響を与えることはできません。
RdKafka
にパーティションを一時停止および再開するAPIがあるかどうかは不明です。私は今すぐJava KafkaConsumer
、その方法#pause()
と#resume()
を提供しています。