使用KStream.toTable().toStream()能否移除同Key旧记录？

你的理解完全正确。

• KTable的核心特性就是仅保留每个Key的最新记录，将KStream转换为KTable时，底层会自动处理同Key的旧记录，只留存该Key对应的最新数据。
• 对这个KTable调用toStream()后，得到的KStream确实只会包含每个Key的最新记录，和你当前用groupByKey().reduce()实现的去重效果完全一致。

补充个细节：两种方式的底层逻辑其实是相通的，toTable()本质上也是基于聚合逻辑（类似reduce）来维护每个Key的最新状态。如果你的需求只是单纯保留每个Key的最新值，toTable().toStream()的写法会更简洁。

内容的提问来源于stack exchange，提问作者Himanshu