通过ksql格式化数据以使用合流jdbc接收器连接器

isr3a4wc  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(306)

我想通过ksql使用汇合jdbc接收器连接器来写入clickhouse数据库。我有一个c应用程序,它将数据写入Kafka主题。如何格式化来自应用程序的消息,以便sink可以写入数据库?我不想使用模式注册表或其他ksql构造。

91zkwejq

91zkwejq1#

ksql接受json或csv数据,但是clickhouse有它自己的kafka连接器,所以不需要jdbc sink,它只处理带有模式的消息(这意味着您需要使用模式注册表,它不仅是ksql构造,还可以在您的c代码中使用)

相关问题