sijie commented on issue #4093: [issue#4042] improve java functions API URL: https://github.com/apache/pulsar/pull/4093#issuecomment-485083825 > Yes but we need this. As I said, it can be add to the wrapper of sendAsync. For handling the output result, I have mentioned following approach in our DM - User can get a message builder through “context.newOutputMessage()” and write a function to return the builder: `MessageBuilder<O> process(I input, Context context);`. Hence the way how people configure the message for result and “context.publish” will be same. I don’t like the propose of “context.setOutputMessageConf”. It is very error-prone. If people didn’t pay attention or then implementation doesn’t handle correctly, the message conf is going to apply to every message, but that’s not the case. Using newOutputMesssage would allow a clear way for configuring message properties per message.
---------------------------------------------------------------- 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
