flink-table-api相关内容

我们可以使用 Flink kafka Upsert 连接器连接到/从 Kafka 压缩的主题吗?

这感觉很明显,但我还是问一下,因为我在文档中找不到明确的确认: Flink 1.12 中可用的 Flink Table API upsert kafka 连接器 与 Kafka 压缩主题的语义非常匹配:将流解释为变更日志并使用 NULL 值作为墓碑来标记删除. 所以我的假设是可以使用它来消费和生产压缩主题,并且它可能正是为此而制作的,尽管它应该可以很好地与非-压缩主题假设其内容确实是一 ..
发布时间:2021-11-12 01:12:32 其他开发

我们可以使用 Flink kafka Upsert 连接器连接到/从 Kafka 压缩的主题吗?

这感觉很明显,但我还是问一下,因为我在文档中找不到明确的确认: Flink 1.12 中可用的 Flink Table API upsert kafka 连接器 与 Kafka 压缩主题的语义非常匹配:将流解释为变更日志并使用 NULL 值作为墓碑来标记删除. 所以我的假设是可以使用它来消费和生产压缩主题,并且它可能正是为此而制作的,尽管它应该可以很好地与非-压缩主题假设其内容确实是一 ..
发布时间:2021-11-12 01:10:23 其他开发