Do <stream>.toTable().toStream() 返回原始流并删除相同键的旧记录？

Question

我有一个

KStream

，它可以包含重复的记录。我可以使用

.groupByKey().reduce()

使用相同的密钥删除旧记录，但想知道我是否也可以通过

.toTable().toStream()

实现这一点？

我的理解是，

.toTable()

将返回仅包含最新记录的

KTable

，并在其上应用

.toStream()

将给出最新记录流，并删除具有相同键的旧记录。这是正确的吗？

Answer 1

你是对的，使用 KTable 可以达到相同的结果，但请考虑到使用 KTable 将创建一个 Rocks 数据库表和一个名为“更改日志主题”的额外主题，并且该数据库表将与更改日志主题。