[FLINK-3384] Create atomic closable queue for communication between Kafka Threads

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.2
• Fix Version/s: 1.0.0
• Component/s: Connectors / Kafka
• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 10/Feb/16 14:58
• Updated: 10/Feb/16 21:44
• Resolved: 10/Feb/16 21:43

Description

As part of extending the Kafka Consumer to handle broker failures without Flink restarts, we need a util to communicate between the main thread and the broker connection thread, and simultaneously track the status of the connection thread.