Skip to content

DataFlow 将结果集输出到 MQTT topic 队列中。

配置方法:

xml
<target type="mqtt"
        table_name="result_join"
        client_id="spark-streaming-mqtt-tid"
        host="localhost"
        port="1883"
        write_type="JSON"
        user_name="name" password="password"
        fields="test_id,test_name,created_at"
        topic="testtopic" />

字段说明:

  1. write_type 将结果以 JSON 形式写入到 exchange;支持 STRING 和 JSON 两种,STRING 则需要 delimiter 分隔符支持;
  2. client_id MQTT 客户端标识,唯一 ID 即可;
  3. user_name 和 password 是可选的,MQTT 如果有认证,则需要;
  4. topic 发送到 MQTT 的 Topic 名称;