eolivelli commented on issue #9899: URL: https://github.com/apache/pulsar/issues/9899#issuecomment-797524691
That was my first idea. We can add that as well. But in Pulsar we are used to automatic decoding of the value, so probably it is good to add getLogicalKey as well, otherwise the Sink code will have to deal explicitly with KeyValueSchema and I believe that it is some kind of implementation detail that is better to hide. In my mind I have that only the KeyValue class is usable by the Sink code, like GenericRecord ---------------------------------------------------------------- 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: [email protected]
