DTStack / DTStack/chunjun

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

Open
#1,779 0 comments 0 reactions 0 assignees View on GitHub
question
Dominant language
Java
Stars
4.1k
Forks
1.7k
PR merge metrics
No merged PRs in 30d

Description

### Search before asking

- [X] I had searched in the [issues](https://github.com/DTStack/chunjun/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](https://dtstack.github.io/chunjun) but it didn't help me.

### Description

![c1230731ebf2e60ed8b5548dc745e10](https://github.com/DTStack/chunjun/assets/41767241/eabf9ecc-1ac2-4c9f-b5ea-0faf5bc42831)

{
"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](https://www.apache.org/foundation/policies/conduct)

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.