Github user pduveau commented on a diff in the pull request: https://github.com/apache/flink/pull/5410#discussion_r193356620 --- Diff: flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig.java --- @@ -109,6 +109,7 @@ private RMQConnectionConfig(String host, Integer port, String virtualHost, Strin * @param requestedChannelMax requested maximum channel number * @param requestedFrameMax requested maximum frame size * @param requestedHeartbeat requested heartbeat interval + * @param createQueue enable or diable queue create on setup --- End diff -- Sorry for this.
---