contributors

master

• name : liutao
• email: [email protected]

developer

• name : fanjiahui
• email:[email protected]
• name : wangyatao
• email: [email protected]

flink sql ddl

CREATE TEMPORARY TABLE rabbitmq_source (
  colunn1 STRING,
  colunn2 STRING,
  colunn3 STRING
) WITH (
  'connector' = 'rabbitmq',
  'queue' = '',
  'hosts' = '',
  'port' = '',
  'virtual-host' = '',
  'username' = '',
  'password' = '',
  'exchange-name'='',
  'format'='json'
);