Kafka Streams应用程序与Kafka JDBC接收器连接器集成

Question

我正在尝试使用kafka流进行某种计算，并将计算结果发送到一个主题，该主题通过JDBC接收器连接器插入数据库。结果需要使用带有合流模式注册表的avro进行序列化。有没有演示或指南来展示如何处理这种情况？

Answer 1

不清楚你所说的"积分"；；Kafka Streams独立于Kafka Connect，但两者都可以从ksqlDB 中使用

使用Streams任务的输出主题，Kafka Connect的现有示例应该足够了

至于Kafka Streams，您需要使用Confluent Avro Serde，并将Schema Registry URL添加到StreamsConfig中。