当KTable和KStream更新到KTable时，KTable是否会发布新的记录？

Question

我在我的应用程序中实现了一个KTable和一个KStream连接，并在以下情况下期望输出消息；

1. ：KStream中的新消息，KTable
2. 中有匹配记录，KStream中有更新的消息，当KTable记录

上有更新时，KTable

• 中有匹配记录

我已经观察到我的应用程序可以像预期的那样执行1和2，而不是3。

有什么建议可以让我达到第三点吗？

谢谢!

Answer 1

您正在寻找一张表连接表。这将在新记录到达任一主题时触发输出消息。

首先要确保您希望跨主题连接的记录具有相同的键，并且是共同分区的。然后将这两个主题读入KTables。

KTable<String, Long> left = ...;
KTable<String, Double> right = ...;

最后，对两个表执行连接。

KTable<String, String> joined = left.join(right, (x, y) -> "left=" + x + ", right=" + y);

https://docs.confluent.io/platform/current/streams/javadocs/javadoc/org/apache/kafka/streams/kstream/KTable.html#join-org.apache.kafka.streams.kstream.KTable-org.apache.kafka.streams.kstream.ValueJoiner-