今、私は samza の基本的なセットアップを行いました。その後、kafka ブローカー トピックからの 1,00,000 json レコードを処理します。各レコードのサイズは 100 バイトですが、1 秒あたり 11000 レコードしか処理できません。処理速度を上げるには？
質問する
162 次
1 に答える
0
より多くのブローカーが必要な場合は、 number partition を増やすことができます:
bin/kafka-topics.sh --zookeeper zoo:port/chroot --alter --topic TOPIC_NAME_CHANGE_ME --partitions 10
nb パーティション == nb ワーカー
詳細情報:ドキュメント
于 2016-03-14T00:24:47.580 に答える