Hi devs and community, I would like to discuss making the low level components of the KafkaSink PublicEvolving. It looks like all of the classes are package private apart from the public facing API and classes were put in the same package to make this work. My desire to make at least the KafkaSinkWriter a public class, with no further changes to private/package-private methods. The class(es) would be annotated with PublicEvolving.
I am in the process of implementing my own Sink that writes to Kafka and I want to implement the SinkWriter by composing the functionality contained in the KafkaSinkWriter. There is significant work in this implementation and I would like to use it and contribute back, bug fixes for example, if I find any in independent testing. Hopefully, that motivates the request. Please let me know your thoughts! Best, Mason
