问答 使用kafka-source读取数据输出为空请问是什么原因?数据是使用binlog-source和kafka-sink插入到kafka里的

使用kafka-source读取数据输出为空请问是什么原因?数据是使用binlog-source和kafka-sink插入到kafka里的

   匿名用户    发布于 2023-08-15 17:26  133  0

  {
"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读取数据输出为空请问是什么原因http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user166259/question/e031be0adc2c295374f079871934ed03..png
  

0条回答
社区公告
  • 大数据领域最专业的产品&技术交流社区,专注于探讨与分享大数据领域有趣又火热的信息,专业又专注的数据人园地

最新活动更多
微信扫码获取数字化转型资料
钉钉扫码加入技术交流群