如何解决格式化数据以通过ksql使用Confluent JDBC Sink连接器
我想通过ksql使用Confluent JDBC Sink Connector来写入ClickHouse数据库。 我有一个将数据写入Kafka主题的c#应用程序。如何格式化应用程序中的消息,以便接收器将其写入数据库是可接受的?我不想使用架构注册表或其他ksql构造。
解决方法
KSQL接受JSON或CSV数据,但是ClickHouse具有它自己的Kafka连接器,因此不需要JDBC Sink,后者仅适用于带有模式的消息(这意味着您将需要使用Schema Registry,而不是只有一个KSQL构造,也可以在您的C#代码中使用)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。