如何将Apache Kafka Connect与Azure Schema Registry集成? &g

Question

我尝试使用confluent avro转换器连接Azure架构注册表(提供架构注册表url和值转换器到avroConverter)，但无法连接。

然后我遇到了下面的repo，它是为Kafka客户端应用程序开发的。但是我怎么用Kafka connect呢?Github Repo: https://github.com/Azure/azure-schema-registry-for-kafka

我可以在代码库中看到他们正在形成TokenCredential对象，并将其与模式注册表url一起发送给KafkaAvroSerializer。我们如何在Kafka connect中做到这一点，因为Kafka生产者被嵌入其中?

感谢

Answer 1

这个repo只适用于Kafka的生产者/消费者API。

您需要创建自己的Converter实现，包装那里可用的序列化器和反序列化器类(然后提交PR，或创建一个问题，要求在那里添加connect模块)。

-现在有一个转换器在该回购。