{
"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
}
}
}
}
使用kafka-source读取数据输出为空请问是什么原因