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


Reply via email to