[Question][kafka-source]使用kafka-source读取数据时为空

[ngchunhoCR7]

Search before asking

• [X] I had searched in the issues and found no similar question.

• [X] I had googled my question but i didn't get any help.

• [X] I had read the documentation: ChunJun doc but it didn't help me.

Description

{ "job": { "content": [ { "reader": { "parameter": { "topic": "chunjun", "timestamp": 1000, "offset": "EARLIEST", "groupId": "dddd", "codec": "json", "column": [ { "name": "id", "type": "int" }, { "name": "name", "type": "varchar" }, { "name": "create_time", "type": "datetime" } ], "consumerSettings": { "bootstrap.servers": "172.16.48.14:9092,172.16.48.16:9092,172.16.48.17:9092", "auto.commit.enable": "false" } }, "name": "kafkasource" }, "writer": { "name": "streamwriter", "parameter": { "print": true } } } ], "setting": { "restore": { "isRestore": true, "isStream": true }, "speed": { "readerChannel": 1, "writerChannel": 1 } } } }

Code of Conduct

• [X] I agree to follow this project's Code of Conduct