我们有一个用例，我想在其中加入两个主题，比如一个键上的topicA和topicB。我想知道topicA数据是否不同步或有一些延迟，处理只是等待它到达。一旦消息是topicA到达，它就在topicB上处理该消息。类似于我们在卡夫卡的左翼加入KTables所能实现的目标。
您在上面描述的是一个"状态联接"；。通常，这是通过自定义RichCoFlatMapFunction(或者KeyedCoProcessFunction，如果您需要计时器之类的东西来过期未连接的记录(来处理的。例如，请参阅https://github.com/apache/flink-training/tree/release-1.11/rides-and-fares辅导的