私は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を割り当てることはできますか?
ソースコード:https://apache.googlesource.com/kafka/+/0.10.0.0-rc4/core/src/main/scala/kafka/tools/ProducerPerformance.scala – unjc