DTStack / DTStack/flinkStreamSQL

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

Aperta
#354 6 commenti 5 reazioni 0 assegnatari Vedi su GitHub
Lingua principale
Java
Stelle
2k
Fork
913
Metriche di merge delle PR
Nessuna PR unita negli ultimi 30g

Descrizione

flinkStreamSQL 1.10的Kafka数据源不支持group-offsets模式,Flink原生版支持的。 在实际应用中,最常用的就是这个模式,Flink原生版本只要设置了groupId, 即使是latest和earlist两种offset模式, 也只是在groupId有新值时,从最新或者最初始开始读,其后就是按照group-offsets来读取的,这样就可以保证任务重启后,准确地衔接上。 希望大佬们可以让flinkStreamSQL 也支持group-offset模式。

Guida per i contributori

Nessuna guida per i contributori indicizzata per questo repository

Valutazione

Questa issue non è ancora stata valutata.

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.