Hello, Im looking into writing a custom kafka connector (used for connecting with a proprietary kafka service). What would be the best way of doing this and also being able to pull changes from the public repo? My first solution was to duplicate the pinot-kafka-2.0 module and adapt that, but this results in a lot of duplicate files and if the original module changes i'll have to reimplement those changes in mine. My changes aren't that big, only to KafkaPartitionLevelConnectionHandler and KafkaPartitionLevelStreamConfig, and a version bump for the kafka client to 2.5

May be extend the existing impl and override whatever needs to be?