在原始ksql中，当前无法对流进行重复数据消除。您也许可以为此编写一个自定义项。
请注意，表只存储给定键的最新更新（消息）。根据您的用例，这可能会有所帮助。