Kafka参数配置
目的
修改Kafka参数,避免Kafka成为瓶颈。
方法
在Storm服务Web界面搜索以下参数并修改:
参数 |
建议值 |
说明 |
---|---|---|
log.dir |
根据实际配置。 |
该值负责配置Kafka数据的保存路径,可以配置为多个目录。 |
num.partitions |
根据实际场景配置。 |
该值负责指定自动创建的Topic分区数,一般配置为Kafka服务节点上的物理盘数之和的1~2倍。 |
num.network.threads |
128 |
该值负责指定Broker用来处理网络请求的线程数目,最大值为128。 |
num.io.threads |
8 |
Kafka Broker处理磁盘IO的线程数。 |
父主题: Storm调优