zengqinchris commented on issue #6006:
URL: https://github.com/apache/seatunnel/issues/6006#issuecomment-1855325215
正确的写法
```
env {
parallelism = 1
job.mode = "BATCH"
checkpoint.interval = 10000
}
source {
Kafka {
format = json
field_delimiter = ","
format_error_handle_way = "fail"
topic = "kv_info"
consumer.group = "kv_info_client_14"
commit_on_checkpoint = true
start_mode = "group_offsets"
bootstrap.servers = "bd212:9092,bd213:9092,bd214:9092"
kafka.config = {
client.id = kv_info_client_14
max.poll.records = 50000
auto.offset.reset = "earliest"
enable.auto.commit = false
}
}
}
transform {
}
sink {
Console {
}
}
```
start_mode = "group_offsets"和 auto.offset.reset = "earliest"都要配置，不然不生效
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
