when using RMQSource in Flink 1.11.2
Hi Thomas,
I am not an expert on RMQSource connector but your concerns look valid.
Could you file a Jira issue in Flink issue tracker? [1]
I cannot immediately refer to a committer who could help with this but let's
hope that the issue gets attention.
I
Hi Thomas,
I am not an expert on RMQSource connector but your concerns look valid.
Could you file a Jira issue in Flink issue tracker? [1]
I cannot immediately refer to a committer who could help with this but
let's hope that the issue gets attention.
If you want to contribute an improvement for
Hi,
we are using the RabbitMQ source connector with exactly-once guarantees. For
this to work, according to the official Flink documentation, we are supplying
correlation IDs with each published message and we use a parallelism of one
with the Flink job being the single/only consumer of the que
