DataFlow StreamSource 支持从 Socket 读取数据流，读取的每行都是一个消息。消息采用 data_type 反序列化，支持 STRING 和 JSON 类型，采用 \n 区分多个消息。

理论上，Streaming 每行读取作为一个消息并反序列化。

<source type="socket" 
        table_name="cust_id_agmt_id_t" 
        duration="30" 
        fields="test_id,test_name,test_status,test_rand,created_at" 
        data_type="STRING" 
        delimiter="," 
        host="localhost" 
        port="8090"/>

配置说明：

1. data_type 消息类型，支持 STRING 和 JSON 两种类型。STRING为字符串行，用于 delimiter 切分；JSON 为 JSONObject String 类型