[FLINK-7267] Add support for lists of hosts to connect

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.3.0
• Fix Version/s: 1.11.0
• Component/s: Connectors/ RabbitMQ
• Labels: pull-request-available
• Assignee: Austin Cawley-Edwards
• Reporter: Hu Hailin
• Created: 26/Jul/17 06:13
• Updated: 16/Oct/20 10:33
• Resolved: 16/May/20 21:07

Description

The RMQConnectionConfig can assign one host:port only. I want to connect to a cluster with an available node.
My workaround is write my own sink extending RMQSink and override open(), assigning the nodes list in it.

      connection = factory.newConnection(addrs)

I still need to build the RMQConnectionConfig with a dummy host:port or a node in list. It's annoying.
I think it is better to provide a configuration for it.

Issue Links

• links to: GitHub Pull Request #12185