我最近注意到，当我提交了两个流应用程序示例并且它们并行工作时，输入速率会发生某种变化。这张图片来自其中一个应用程序，当时我杀死了另一个。投入率提高。

我正在从mqtt messagebroker订阅以将数据获取到应用程序。这是否意味着负载在两个应用程序之间分配？
更多信息：在应用程序处理数据之后，它会被写入hbase，并且事务是幂等的，如果数据被写入两次，则不会发生任何事情。