我正在尝试在Kafka Streams中使用一个简单的外键连接,类似于许多文章(例如:https://www.confluent.io/blog/data-enrichment-with-kafka-streams-foreign-key-joins我们的最终目标是每次更新任何一个表中的任何字段时,都将AccountRecord传递到一个主题。问题是,当我简单地分别打印user表和account表时,外键和所有字段都是完全填充的。下面是我的代码片段: public void start_tes
我有一个输入流,我用它来创建一个ktable。然后,我使用toStream()方法使用ktable changelog创建一个输出流。问题是toStream()方法创建的流并不包含来自更新了我的KTable的输入流的所有消息。下面是我的代码: final KTable<String, event> KTable = inputStream.groupByKey().aggregate(() -> n