现在我做了 samza 的基本设置。之后,我处理来自 kafka 代理主题的 1,00,000 条 json 记录,每条记录大小为 100 字节,但每秒我只能处理 11000 条记录。如何提高处理速度?
问问题
162 次
1 回答
0
如果您需要更多经纪人,您可以增加号码分区:
bin/kafka-topics.sh --zookeeper zoo:port/chroot --alter --topic TOPIC_NAME_CHANGE_ME --partitions 10
所以 nb 分区 == nb worker
欲了解更多信息:文档
于 2016-03-14T00:24:47.580 回答