EMQX5.1 10wTPS应该用什么方式消费

EMQX 版本

EMQX 5.1

EMQX Operator 2.2.0 alpha 部署

具体问题

目前用的最新的operator和版本是否稳定
10wTPS并发 北向推到tsdb 应该用什么方式 共享订阅还是扩展插件,性能分别能达到什么程度

如果是开源版本的,建议你用Flink 自定义Mqtt SourceFunction 采用共享订阅的方式,每个solt或者并行度起一个连接. 如果是企业版,那就转到kakfa吧。然后flink消费kafka。tsdb的吞吐量多大不知道.StarRocks的吞吐量是可以到60万的,3台服务器集群的话。

2 个赞