Hu Hailin created FLINK-7267: -------------------------------- Summary: Add support for lists of hosts to connect Key: FLINK-7267 URL: https://issues.apache.org/jira/browse/FLINK-7267 Project: Flink Issue Type: Improvement Components: RabbitMQ Connector Affects Versions: 1.3.0 Reporter: Hu Hailin Priority: Minor
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. -- This message was sent by Atlassian JIRA (v6.4.14#64029)