我一直在为我的一个用例探索apachestorm。喷口将读取数据从我自己的Kafka实现，它将传递给螺栓。
我的拓扑结构对于单个消费群体的工作速度更快。如果我增加拓扑中使用者组的数量，我可以看到处理缓慢，尽管我有专门用于所有使用者组的每个分区的喷口和螺栓。
调试时，我发现在处理过程中发生了更多的上下文切换，因此记录了处理螺栓的线程名称。我可以看到，有时不同的执行器线程传递相同的螺栓id。
我怀疑，由于这可能会有上下文切换可能会发生，并由于cpu线程缓存错过，有可能在延迟增加。
我的假设是否正确。如果是这种行为，是否有任何选项可以通过同一个执行线程设置任务，而不是将其传递给另一个执行线程。