cmick commented on pull request #16472: URL: https://github.com/apache/flink/pull/16472#issuecomment-883423712
@fapaul I can write an integration test that would start RabbitMQ, write something to the queue, start Flink job, and check whether all messages are read correctly. So it would effectively test whether the messages are consumed correctly. Is that what you had in mind? But for this specific problem, I don't know if it would be possible to simulate. For the above to occur, the source must be interrupted (e.g. Flink failure, connection timeout) exactly during the acknowledgment. So, it's easy to mock, but would be difficult repeat in a test. But maybe you would have any suggestion? -- 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]
