eolivelli edited a comment on issue #9899: URL: https://github.com/apache/pulsar/issues/9899#issuecomment-797507997
Here I am talking more about the Sink part, that is when we read from Pulsar. But yes, my idea is that we are able to ready the "logical key", whatever it is. - raw byte[] - String - KeyValue - SEPARATED - KeyValue - INLINE I believe that the optimal situation it to see a "Record" as a pair of Object,Object record.getValue() -> logical "value" record.getKeyObject() -> logical "key" maybe a better name is `getLogicalKey` ? ---------------------------------------------------------------- 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]
