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" />字段说明:
- write_type 将结果以 JSON 形式写入到 exchange;支持 STRING 和 JSON 两种,STRING 则需要 delimiter 分隔符支持;
 - client_id MQTT 客户端标识,唯一 ID 即可;
 - user_name 和 password 是可选的,MQTT 如果有认证,则需要;
 - topic 发送到 MQTT 的 Topic 名称;
 
