bezmax commented on issue #6161: Cloning subscriptions URL: https://github.com/apache/pulsar/issues/6161#issuecomment-581649655 I have reread how asynchronous operators work in Flink and yes, Reader approach would suffice the way @yjshen has described. I'll close this feature request. I was under assumption that async operators are inherently stateless, meaning that if my asynchronous processing of message fails - source would be responsible to redeliver original on recovery. Now I found out that async operators actually store full set of unprocessed messages and redeliver them on failure - effectively implementing what I was asking for here but on Flink side. Probably the only downside of this is - I can not have multiple sources for same partition, but with high enough partition count this is also not a big deal. Thanks for the help and sorry for taking your time.
---------------------------------------------------------------- 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
