syhily commented on PR #21069: URL: https://github.com/apache/flink/pull/21069#issuecomment-1281843417
The main cause of this fix is just because some bugs in Pulsar. Pulsar always wrap single message id into a batch message id. This fix will throws detailed exception with batch message size. I don't think we need to test on this wired situation? This is only a guarding fix. -- 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]
