DataFlow StreamSource 支持RocketMQ 消息引擎。

<source type="rocketmq"
        table_name="cust_id_agmt_id_t"
        duration="30"
        topic="testtopic"
        fields="test_id,test_name,test_begintime,test_endtime,test_status,test_dsc,test_b,test_c,test_rand,created_at"
        key_data_type="STRING"
        value_data_type="STRING"
        delimiter=","
        nameserver_addr="localhost:9876"/>

说明：

1. Topic： 是 rocketmq topic；
2. Nameserver_addr: 是 rocketmq_name server 地址；
3. Key_data_type 和 value_data_type 是控制 RocketMQ message 的类型，可选：STRING、JSON；