当 K 表中缺少键时，处理 K 流与 K 表的联接

Question

我最近开始尝试kafka流。我有一个场景，我需要用KTable加入KStream。可能是因为KTable不包含某些键。在这种情况下，我会得到一个NullPointerException。

具体来说，我得到了

StreamThread-1在处理过程中流应用程序错误：java.lang.NullPointerException

我不知道我该如何处理这个问题。我无法以某种方式过滤掉与表条目不对应的流记录。

使现代化

进一步查看，我发现我可以通过 ReadOnlyKeyValueStore 接口查询基础存储以查找是否存在密钥。

在这种情况下，我的问题是，这是最好的办法吗？即基于本地存储中是否存在关键字来过滤要加入的流？

在这种情况下，我的第二个问题是，由于我关心在下一阶段利用版本10.2中引入的Global State Store，我是否应该期望我也能够以同样的方式查询Global State Store？

更新

之前的更新不准确，因为无法从拓扑内部查询状态存储

最终更新

在更好地理解了连接语义之后，我能够通过简化< code>valueJoiner来解决这个问题，只返回结果，而不是对连接的值执行操作，并在连接之后添加一个额外的过滤步骤来过滤掉空值。

Answer 1

我的问题的解决方案来自于对< code>join语义的更好理解。

就像在数据库联接中一样（尽管我并不是说Kstream联接完全遵循db联接概念），左联接操作会导致缺少右侧键的行具有空值。

所以最终我唯一要做的就是将我的value eJoiner与后续的计算/操作分离（我需要对连接记录的字段执行一些计算并返回一个新构造的对象），并且让它只返回一个连接值的数组。然后我可以通过检查这些数组来过滤掉导致null值的记录。

根据Matthias的J.Sax建议，我使用了0.10.2版本，而不是0.10.1logic替换为内部联接，这样就不需要过滤出0.05的null值。