DTStack / DTStack/flinkStreamSQL
希望flinkStreamSQL 1.10的Kafka数据源可以像flink原生版一样支持group-offsets模式
Open
- Dominant language
- Java
- Stars
- 2k
- Forks
- 913
- PR merge metrics
- No merged PRs in 30d
Description
flinkStreamSQL 1.10的Kafka数据源不支持group-offsets模式,Flink原生版支持的。 在实际应用中,最常用的就是这个模式,Flink原生版本只要设置了groupId, 即使是latest和earlist两种offset模式, 也只是在groupId有新值时,从最新或者最初始开始读,其后就是按照group-offsets来读取的,这样就可以保证任务重启后,准确地衔接上。 希望大佬们可以让flinkStreamSQL 也支持group-offset模式。
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.