【发布时间】:2021-07-01 10:55:13
【问题描述】:
我有关于 Kafka 主题的 Avro Schema 表的数据。现在我想根据特定列的值过滤该数据。那么我应该使用哪一个呢?
【问题讨论】:
-
您要过滤它们并重新存储在 kafka 中吗?
标签: apache-kafka apache-kafka-streams
我有关于 Kafka 主题的 Avro Schema 表的数据。现在我想根据特定列的值过滤该数据。那么我应该使用哪一个呢?
【问题讨论】:
标签: apache-kafka apache-kafka-streams
此操作不需要KTable。 filter() is a stateless operation on a KStream.
【讨论】: