xiaochen-zhou commented on PR #141: URL: https://github.com/apache/flink-connector-kafka/pull/141#issuecomment-2548084763
> Afaik this doesn't work and was the main reason for #100. If you last message is a transaction marker, then you would never check the stop condition on that partition at the point in time. > > I'll trigger the CI which should fail for the test that was specifically added for that scenario. > > I'll leave this PR open untli we figured out if it can indeed be improved. Please double check the linked PR and the respective ticket. OK. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
