是否有连接到 ksqldb 表的 Flink sink 连接器？

【问题标题】：Is there Flink sink connector to ksqldb tables?是否有连接到 ksqldb 表的 Flink sink 连接器？
【发布时间】：2021-12-15 03:24:09
【问题描述】：

我有工作的 Flink 应用程序，所有输出都输出到标准输出。我想将结果插入到 ksqldb 表中。有没有 Flink 连接器？

【问题讨论】：

【解决方案1】：

每个 ksqldb 表总是有一个支持主题 (the KAFKA_TOPIC parameter)。

您可以使用Flink Kafka connector在此主题中插入数据

【讨论】：

还有一个用于 Flink SQL 的 Upsert Kafka 连接器（如果需要，可以从 DataStream API 使用它）。 nightlies.apache.org/flink/flink-docs-stable/docs/connectors/…