我正在读Kafka两个主题的资料。可以描述为： Topic1 data content: VehicleRegistrationNo, Timestamp, Location Topic2 data content: VehicleRegistrationNo, Timestamp, Speed 我需要根据最接近的时间戳合并这两条消息，并将元组作为消息输出 VehicleRegistrationNo, Timestamp, Speed, Location . 我通过两个喷口阅读这些主题 S1 以及 S2 . 然后螺栓 MergeS1andS2 从这些喷口获取输入，并作为： if (message from S1): save present message from S1 along with 2 previous messages (3 consecutive locations) to LocationHashMap elseif (message from S2): get locations details from LocationHashmap and merge speed for same Vehicle with location info, then send details to next bolt as tuple 我知道hashmap不是在多节点中存储数据的有效方法。所以我读了关于trident和redis来存储中间数据。在这个可以在分布式拓扑中工作的senario中，我应该使用什么来存储中间数据。