DataFlow StreamSource 支持 MQTT 协议，从 MQTT 消费消息。

<source type="mqtt" 
        table_name="cust_id_agmt_id_t" 
        duration="30" 
        topic="testtopic" 
        fields="test_id,test_name,test_status,test_dsc,test_b,test_c,test_rand,created_at" 
        data_type="STRING" 
        delimiter="," 
        client_id="for_bar"
        user_name="admin" 
        password="123456" 
        host="localhost" 
        port="1883" />

配置说明：

1. client_id MQTT 客户端标识，唯一 ID 即可， 非必须;
2. user_name MQTT 服务账号，非必须；
3. password MQTT 服务密码，非必须；
4. topic MQTT Topic 订阅主题；
5. data_type MQTT 消息类型，支持 STRING 和 JSON 两种类型。STRING为字符串行，用于 delimiter 切分；JSON 为 JSONObject String 类型