SEZ9 commented on issue #12700: URL: https://github.com/apache/seatunnel/issues/12700#issuecomment-6097821081
Thanks for the detailed analysis. The 6 + 14 = 20 split across two template invocations lines up with the two compounding causes you describe: the read in `getRocketMqConsumerData` not waiting for the written rows to become visible, and the shared topic/consumer group letting the next invocation inherit the shortfall through the committed offset. As noted above, the fix is being tracked in #12701, which gives each template invocation its own topic and waits for the expected rows to become visible before the single consuming read, covering the three sink tests listed in the report (`testSinkRocketMq`, `testTextFormatSinkRocketMq`, `testSinkRocketMqMessageTag`). Please keep follow-up in that PR rather than opening a separate implementation PR. If you have a link to the failing CI run, adding it to #12701 would help with review. <!-- streview-comment:1655 --> -- 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]
