到目前为止，连接 Quarkus 应用到 Apache Kafka 并通过主题生产和消费消息/事件是非常容易的。消费 Kafka 消息很简单，只要有消息生成，我们就可以得到它们，但是除此之外，我们也做不了其他的事情了。如果我们需要实时处理数据（比如过滤或操作事件）的话，又该怎么办呢？如果我们需要对事件做一些关联，又该怎么办呢（比如，_playedmovie_事件中包含电影的，但是我们该如何与_Movie_主题联合起来获取电影的名字呢）？
互联网应该属于每个人......
到目前为止，连接 Quarkus 应用到 Apache Kafka 并通过主题生产和消费消息/事件是非常容易的。消费 Kafka 消息很简单，只要有消息生成，我们就可以得到它们，但是除此之外，我们也做不了其他的事情了。如果我们需要实时处理数据（比如过滤或操作事件）的话，又该怎么办呢？如果我们需要对事件做一些关联，又该怎么办呢（比如，_playedmovie_事件中包含电影的，但是我们该如何与_Movie_主题联合起来获取电影的名字呢）？
