通过 ksql 格式化数据以使用 Confluent JDBC Sink Connector

【问题标题】：Formatting data to use Confluent JDBC Sink Connector via ksql通过 ksql 格式化数据以使用 Confluent JDBC Sink Connector
【发布时间】：2020-12-11 07:47:40
【问题描述】：

我想通过 ksql 使用 Confluent JDBC Sink Connector 来写入 ClickHouse 数据库。我有一个将数据写入 Kafka 主题的 c# 应用程序。如何格式化来自我的应用程序的消息，以便接收器可以接受写入数据库？我不想使用 Schema Registry 或其他 ksql 构造。

【问题讨论】：

标签： jdbc apache-kafka apache-kafka-connect ksqldb

【解决方案1】：

KSQL 接受 JSON 或 CSV 数据，但是 ClickHouse 有它自己的 Kafka 连接器，因此不需要 JDBC Sink，它只适用于带有模式的消息（这意味着您需要使用模式注册表，它不是只是一个 KSQL 结构，也可以在你的 C# 代码中使用）

【讨论】：