eolivelli commented on issue #9899: URL: https://github.com/apache/pulsar/issues/9899#issuecomment-797575292
@vroyer that's something I would like to achieve but we have to take into account compatibility with the past with https://github.com/apache/pulsar/pull/9896 we will open the way to Sink<Object> , and in that case Record.getValue() will contain your KeyValue object if you are coming from a KeyValue encoded message. we could also create a new interface KeyValueRecord with your code and add some Record#toKeyValueRecord() converter that maps the Record to the new API ---------------------------------------------------------------- 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]
