我尝试使用kafka流进行某种计算，并将计算结果发送到一个主题，该主题通过jdbc sink connector下沉到数据库中。结果需要使用avro和合流模式注册表进行序列化。有没有演示或指南来说明如何处理这种情况？
xjreopfe1#
不清楚“整合”是什么意思；kafka流独立于kafka connect，但是两者都可以从ksqldb使用使用streams任务的输出主题，kafka connect的现有示例应该足够了至于kafka流，您需要使用合流的avroserde并将schema注册表url添加到streamsconfig。
1条答案
按热度按时间xjreopfe1#
不清楚“整合”是什么意思；kafka流独立于kafka connect，但是两者都可以从ksqldb使用
使用streams任务的输出主题，kafka connect的现有示例应该足够了
至于kafka流，您需要使用合流的avroserde并将schema注册表url添加到streamsconfig。