DTStack / DTStack/flinkStreamSQL

希望flinkStreamSQL 1.10的Kafka数据源可以像flink原生版一样支持group-offsets模式

Open
#354 6 comments 5 reactions 0 assignees View on GitHub
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.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.