过滤数据-KStream还是KTable



我有一个Kafka主题上Avro Schema中的表的数据。现在,我想根据特定列的值来筛选数据。那么我应该用哪一个呢?

此操作不需要KTable。CCD_ 2是对CCD_ 3的无状态操作。

相关内容

  • 没有找到相关文章

最新更新