如何使用apache samza每秒處理120萬條消息？

Question

現在我做了samza的基本設置。 之後，我處理1,00,000個來自卡夫卡經紀人主題的json記錄 每個記錄的大小爲100字節 但是，我每秒只能處理11000條記錄。 如何提高處理速度？

Answer 1

如果你需要更多的代理，你可以增加數分區：

bin/kafka-topics.sh --zookeeper zoo:port/chroot --alter --topic TOPIC_NAME_CHANGE_ME --partitions 10 

所以NB分區== NB工人

欲瞭解更多信息：Documentation