Hello everyone, here in our Pulsar repository we have a simple Kafka Connector for Pulsar IO composed by a Sink and a Source. https://github.com/apache/pulsar/tree/master/pulsar-io/kafka
I have started to work on a set of enhancements to this connector in order to make it more powerful and to better fit the needs of enterprise users. The first patch I have submitted is about supporting Avro encoded messages + Confluent Schema Registry in the KafkaSource https://github.com/apache/pulsar/pull/9448 The patch is only the first one of a bigger work that we have to do in order to have a fully usable Connector for non-trivial use cases. I will be happy to follow up with other patches and especially to draw a little roadmap about the features that we want to implement and provide to the community. Please take a look to the patch and share your thoughts Regards Enrico
