[FLINK-2624] RabbitMQ source / sink should participate in checkpointing

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.0
• Fix Version/s: 1.0.0
• Component/s: Connectors / Common
• Assignee: Hilmi Yildirim
• Reporter: Stephan Ewen
• Created: 04/Sep/15 14:43
• Updated: 12/Oct/16 18:06
• Resolved: 12/Oct/16 18:05

Description

The RabbitMQ connector does not offer any fault tolerance guarantees right now, because it does not participate in the checkpointing.

We should integrate it in a similar was as the FlinkKafkaConsumer is integrated.