我正在努力实现我的风暴设置最大的性能。我通过Kafka发送了数以万计的信息，风暴拓扑会收到这些信息。当我在StormUI中查看时，我注意到所有消息都将发送给单个执行器，而不是在所有执行器之间进行负载平衡(请参见随附的屏幕截图）。有什么原因吗？我怎样才能平衡Kafka消息的负载？storm ui截图
ryhaxcpt1#
由于您有3个分区，请尝试创建kafka喷口（parallelism提示为3）和hbase bolt（parallelism提示为3）。在hbase螺栓中使用部分密钥分组，以便基于密钥在螺栓之间对消息进行负载平衡。
1条答案
按热度按时间ryhaxcpt1#
由于您有3个分区，请尝试创建kafka喷口（parallelism提示为3）和hbase bolt（parallelism提示为3）。在hbase螺栓中使用部分密钥分组，以便基于密钥在螺栓之间对消息进行负载平衡。