DTStack / DTStack/flinkStreamSQL

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

Ouverte
#354 6 commentaires 5 réactions 0 personnes assignées Voir sur GitHub
Langage dominant
Java
Étoiles
2k
Forks
913
Métriques de merge des PR
Aucune PR mergée en 30 j

Description

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

Guide de contribution

Aucun guide de contribution indexé pour ce dépôt

Évaluation

Cette issue n'a pas encore été évaluée.

Recevez les nouvelles issues par e-mail

Un résumé court des issues GitHub adaptées aux débutants.