sijie commented on issue #4110: Function should support `Message<T>` URL: https://github.com/apache/pulsar/issues/4110#issuecomment-486014864 @jerrypeng yes. there is already a `getCurrentRecord`. However the Record interface doesn't catch up the Message interface, hence there are a few fields are not added. e.g. publish time, schema version and redelivery count. As I mentioned in the discussion in #4093 , the problem of having two interfaces is that it is really hard to make them consistent with each other. There are a couple of options here: 1) we catch up the interface in Record api. but the problem still exists since anytime people make changes to Message api. The metadata will be first lost at Record api until someone add it. 2) we add `getCurrentMessage` to return the current message. 3) the proposal here. I don't have any strong opinion with any approach here. However if we take 3), we might be able to support `Message<T>` in java native function.
---------------------------------------------------------------- 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] With regards, Apache Git Services
