Currently we have one connector for Kafka, now when making another connector for Azure, we can reuse the connector, for that it needs to be migrated to our SDK, this will also make it easier for users to make their own connectors.

While migrating the connector  will keep the behavior, but some small code parts will be changed to make it generic.

Afterwards needs to be changed in the example as well.