sijie commented on issue #2330: Function localrun quits when using partitioned topic. URL: https://github.com/apache/incubator-pulsar/issues/2330#issuecomment-411305563 I had a discussion with @codelipenghui . the original question was around stateful function. stateful function was shipped as a preview feature in 2.1. however it is not fully integrated in cluster mode. so I will be working on that piece in #2335 . However there is a bigger problem around `partitioned-topic`. It seems there is some regression in partitioned topic in 2.1, which pulsar functions can't run with `partitioned-topic`. because we switched to using multi-topic subscription in 2.1, so it will return a partition name instead of topic name, which cause function runtime confused on finding a suitable serde to deserialize the message and it throws RuntimeException and quits. I marked this issue as `bug` and updated the issue title to be more specific. this fix should also be cherry-picked to 2.1.1 release as well.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on 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
