我想通过ksql使用汇合jdbc接收器连接器来写入clickhouse数据库。我有一个c应用程序,它将数据写入Kafka主题。如何格式化来自应用程序的消息,以便sink可以写入数据库?我不想使用模式注册表或其他ksql构造。
91zkwejq1#
ksql接受json或csv数据,但是clickhouse有它自己的kafka连接器,所以不需要jdbc sink,它只处理带有模式的消息(这意味着您需要使用模式注册表,它不仅是ksql构造,还可以在您的c代码中使用)
1条答案
按热度按时间91zkwejq1#
ksql接受json或csv数据,但是clickhouse有它自己的kafka连接器,所以不需要jdbc sink,它只处理带有模式的消息(这意味着您需要使用模式注册表,它不仅是ksql构造,还可以在您的c代码中使用)