2017-03-13 9 views
2

私はkafkaをかなり新しくしており、カフカのクォータシステムの仕組みを理解したいと思っています。今まで私は、次のコマンドを使用して、新しいクライアントのためのクォータを(生産と消費)を設定することができたhereクライアントとユーザのためのカフカの割り当て

文書次されている

ビン/ kafka-configs.sh --zookeeper 10.11.10.2:2181 --alter --add-config設定 'producer_byte_rate = 1024、consumer_byte_rate = 1024' --entity型クライアント--entity名クライアントA

私はまた、次のコマンドを使用していますスループットを測定するカフカのトピックのUT

ビン/ kafka-producer-perf-test.sh --topic topic1 --numレコード100000 --recordサイズ100000 500000 --throughput --producer-小道具のACKを= 0ブートストラップ.servers = 10.11.10.2:9092

特定のプロデューサにclient-idを割り当てる方法がわかりません。基本的には、特定のクライアントIDを使用してkafka-producer-perf-testを実行します。

これは可能ですか?また、ユーザークォータとクライアントクォータの違いは何ですか?特定のプロデューサにuser-idを割り当てることはできますか?

答えて

1

kafka.tools.ProducerPerformanceのソースコードがkafka-producer-test.shによって呼び出されているため、 "client.id"は "producer-performance"を使用して(少なくともバージョン0.10以前では)ハードコーディングされています" kafka-producer-perf-testスクリプトを実行する場合、特定のクライアントのクォータを設定する必要があります。

+0

ソースコード:https://apache.googlesource.com/kafka/+/0.10.0.0-rc4/core/src/main/scala/kafka/tools/ProducerPerformance.scala – unjc

関連する問題