kafka-doris存在问题
Search before asking
- [X] I had searched in the issues and found no similar issues.
What happened
{ "job": { "content": [ { "reader": { "parameter": { "topic": "test", "mode": "earliest-offset", "codec": "json", "columns": [ { "name": "id", "type": "INT"
},
{
"name": "device_id",
"type": "STRING"
}
],
"consumerSettings": {
"bootstrap.servers": "172.18.8.203:9092",
"auto.commit.enable": "false"
}
},
"name": "kafkasource"
},
"writer": {
"parameter": {
"database": "db_test",
"table": "test1",
"username": "root",
"password": "",
"feNodes":
"172.18.8.207:8130"
,
"columns": [
{
"name": "id",
"comment": null,
"type": "INT",
"columnDisplaySize": 3,
"precision": 11,
"ifPrimaryKey": false,
"isnull": 1
},
{
"name": "device_id",
"comment": null,
"type": "varchar",
"columnDisplaySize": 85,
"precision": 85,
"ifPrimaryKey": false,
"isnull": 1
}
]
},
"name": "doriswriter"
}
}
],
"setting": {
"speed": {
"channel": 1
}
}
} }
What you expected to happen
原因:kafka接收数据往doris写入时,header为空,value有数据

How to reproduce
原因:kafka接收数据往doris写入时,header为空,value有数据

Anything else
No response
Version
1.12_release
Are you willing to submit PR?
- [X] Yes I am willing to submit a PR!
Code of Conduct
- [X] I agree to follow this project's Code of Conduct
我已解决了
怎么解决的呢,如果是chunjun的原因,可以提个pr
代码问题
能否提个pr
可以
---原始邮件--- 发件人: @.> 发送时间: 2023年3月27日(周一) 下午2:17 收件人: @.>; 抄送: @.@.>; 主题: Re: [DTStack/chunjun] kafka-doris存在问题 (Issue #1574)
能否提个pr
— Reply to this email directly, view it on GitHub, or unsubscribe. You are receiving this because you authored the thread.Message ID: @.***>