[BEAM-6843] RabbitMqIO: com.rabbitmq.client.ShutdownSignalException - 406 PRECONDITION_FAILED

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Duplicate
• Fix Version/s: Not applicable
• Component/s: io-java-rabbitmq
• Assignee: Unassigned
• Reporter: Augustin Lafanechere
• Created: 15/Mar/19 11:32
• Updated: 24/Jul/20 19:54
• Resolved: 15/Mar/19 11:38

Description

Using the RabbitMqIO as an unbounded source I encounter exceptions when messages are acknowledged.

Reading the code of the IO I understood that ACK are sent when finalizeCheckpoint is called.

 

If I understand the exception well, it's raised when messages are not acked in same order as they arrive to the system.

Is there something I can do in my pipeline to avoid this exception ? Maybe something needs to be done on RabbitMQ side.

Thanks for your help