eolivelli commented on pull request #10878: URL: https://github.com/apache/pulsar/pull/10878#issuecomment-858353335
@merlimat the KeyValueSchema class is an important case. if we go this way I would like to add a new public interface that represents KeyValueSchema and is it usable by the Sink. something like org.apache.pulsar.client.api.KeyValueSchema (next to Schema) It was something that I wanted to bring up before, but I did not chime in about the lack of such API in 2.8.0 we did much work in order to support KeyValue in Pulsar Sink and we should not break this now. I can volunteer to add such class and retrofit the integration tests -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org