KStreams - KTable 启动阶段

Question

KStreams - KTable 连接的工作方式非常简单：每次在流上发出新样本时，都会在表上执行键查找。

这会在瞬态阶段产生意外行为吗？我们有这样的拓扑：

1. 一个KStream A，我们执行 selectKey 将其转换为 Stream A1
2. 一个KStream B，我们groupBy然后减少，变成一个KTable B1

在启动时，我们在 A 上发布两条记录，在 B 上发布两条记录，这样在 A 上的 selectKey 和 B 上的 groupBy + reduce 之后，key 就会匹配。但是，我们注意到有时 A1 和 B1 之间的内部连接的样本会失败，而我们会丢失一些我们期望的输出。

确保没有更新丢失的正确拓扑是什么？

Answer 1

KStream-KTable 加入同步是最好的努力。我们致力于改进，为 1.2 版本提供更好的保证。 Atm，你无能为力。

如果您需要严格的保证，则需要使用transform() 而不是join() 实现自己的流表连接运算符。您可以将 KTable 存储连接到 Transformer，并为连接查找放置自定义逻辑。