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:
us...@infra.apache.org
With regards,
Apache Git Services
