2017-02-01 2 views

答えて

1

コンシューマは、(一時停止されていない)すべてのトピックパーティションをポーリングします。ブローカは、返すデータを決定します。ブローカーの行動に直接影響を与えることはできません。

RdKafkaにパーティションを一時停止および再開するAPIがあるかどうかは不明です。私は今すぐJava KafkaConsumer、その方法#pause()#resume()を提供しています。

関連する問題