| commit | e6451377e697ff6dd26f6f08394a2018c2fb1ed2 | [log] [tgz] |
|---|---|---|
| author | Michal Ciesielczyk <michal.ciesielczyk@deep.bi> | Mon Jul 05 20:01:39 2021 +0200 |
| committer | MartijnVisser <martijn@2symbols.com> | Tue Dec 13 10:40:47 2022 +0100 |
| tree | 5ed8fdf2c771e96005b3ffe5ade2f0cc2979cd31 | |
| parent | 654d6d06f0ce63fc0d008d1e25e714f11ffbfa72 [diff] |
[FLINK-23183][connectors/rabbitmq] Fix ACKs for redelivered messages in RMQSource and add integration tests Changes: - channel.basicReject in RMQSource is called in case of already processed (and checkpointed) but redelivered messages (e.g. after the job failover) - add integration test that verifies that the source actually consumes the messages - add integration test reproducing the message redelivery issue in case of ack failure