syhily commented on pull request #17643: URL: https://github.com/apache/flink/pull/17643#issuecomment-959003085
@wsz94 The data loss is confusing. I think we need more tests on this situation. After discussing with my Pulsar team member and test on my local machine. The pending wouldn't be removed. This is a bug on the Pulsar side. We can have a patch for the reader. But it should be fixed on pulsar client. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
