zengqinchris commented on issue #4549:
URL: https://github.com/apache/seatunnel/issues/4549#issuecomment-1855281676
大佬们，你们指定 start_mode = "group_offsets"
可以消费数据吗，我的一直不能消费数据，换成新的消费者组也是不行的，只能消费新的数据，之前的历史数据，只能消费新的数据
env {
parallelism = 1
job.mode = "STREAMING"
checkpoint.interval = 15
}
source {
Kafka {
format = json
field_delimiter = ","
json.fail-on-missing-field = false
json.ignore-parse-errors = true
format_error_handle_way = "fail"
topic = "kv_info"
consumer.group = "kv_info_client_12"
commit_on_checkpoint = true
start_mode = "group_offsets"
bootstrap.servers = "bd212:9092,bd213:9092,bd214:9092"
kafka.config = {
client.id = kv_info_client_12
max.poll.records = 50000
enable.auto.commit = false
}
}
}
transform {
}
sink {
Console {
}
}
--
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]
