DTStack / DTStack/flinkStreamSQL
希望flinkStreamSQL 1.10的Kafka数据源可以像flink原生版一样支持group-offsets模式
オープン
- 主要言語
- Java
- スター
- 2k
- フォーク
- 913
- PR マージ指標
- 30日以内にマージされた PR はありません
説明
flinkStreamSQL 1.10的Kafka数据源不支持group-offsets模式,Flink原生版支持的。 在实际应用中,最常用的就是这个模式,Flink原生版本只要设置了groupId, 即使是latest和earlist两种offset模式, 也只是在groupId有新值时,从最新或者最初始开始读,其后就是按照group-offsets来读取的,这样就可以保证任务重启后,准确地衔接上。 希望大佬们可以让flinkStreamSQL 也支持group-offset模式。
コントリビューションガイド
このリポジトリのコントリビューションガイドは索引されていません
評価
この issue はまだ評価されていません。