希望flinkStreamSQL 1.10的Kafka数据源可以像flink原生版一样支持group-offsets模式
Dieses Issue hat noch niemand übernommen.
Bewertung
- Schwierigkeit
- 4/5
- Geschätzter Aufwand
- 3-5 Tage
- Anfängerfreundlichkeit
- 35/100
- Issue-Typ
- Feature
- Klarheit
- Größtenteils klar
- Aktivitätsstatus
- Veraltet
- Bereich
- stream-processing
Rechercherichtung
Im Issue wird keine Datei, kein Test und kein Einstiegspunkt genannt. Beginne damit, die Kafka-Quellkonfiguration von FlinkStreamSQL 1.10 und deren Behandlung des Offset-Modus zu lokalisieren, und vergleiche sie anschließend mit Flinks Verhalten bei group-offsets; abgeschlossen ist die Aufgabe, wenn eine konfigurierte groupId die Verarbeitung bei den festgeschriebenen Gruppen-Offsets fortsetzt und dabei das anfängliche latest- oder earliest-Verhalten für eine neue Gruppe beibehält.
Vom Indexierungsmodell aus dem Issue-Text verfasst.
Beschreibung
flinkStreamSQL 1.10的Kafka数据源不支持group-offsets模式，Flink原生版支持的。 在实际应用中，最常用的就是这个模式，Flink原生版本只要设置了groupId， 即使是latest和earlist两种offset模式, 也只是在groupId有新值时，从最新或者最初始开始读，其后就是按照group-offsets来读取的，这样就可以保证任务重启后，准确地衔接上。 希望大佬们可以让flinkStreamSQL 也支持group-offset模式。
- Vorherrschende Sprache
- Java
- Sterne
- 2k
- Forks
- 913
- PR-Merge-Kennzahlen
- Keine gemergten PRs in 30 T.
Beitragsleitfaden
Für dieses Repository ist kein Beitragsleitfaden indexiert
Erste Schritte
- Lesen Sie das ganze Issue und danach den Beitragsleitfaden des Projekts.
- Schreiben Sie ins Issue, dass Sie es übernehmen — das erspart doppelte Arbeit.
- Forken Sie das Repository und arbeiten Sie in einem Branch.
- Öffnen Sie einen Pull Request, der die Issue-Nummer nennt.
Mehr aus DTStack/flinkStreamSQL
-
Schwierigkeit 5/5 Über eine Woche Anfängerfreundlichkeit 20/100
DTStack/flinkStreamSQL#467 · 1 Kommentar ·
-
Schwierigkeit 4/5 3-5 Tage Anfängerfreundlichkeit 25/100
DTStack/flinkStreamSQL#437 · 3 Kommentare ·
-
Schwierigkeit 3/5 1-2 Tage Anfängerfreundlichkeit 38/100
DTStack/flinkStreamSQL#432 · 1 Kommentar ·
-
Schwierigkeit 5/5 Über eine Woche Anfängerfreundlichkeit 15/100
DTStack/flinkStreamSQL#431 ·
-
有无对sql 语法校验的方法 Offen
Schwierigkeit 5/5 Über eine Woche Anfängerfreundlichkeit 15/100
DTStack/flinkStreamSQL#430 · 1 Kommentar ·
Alle Issues in DTStack/flinkStreamSQL
Ähnliche Issues
-
area-deployment area-integrations triage:bot-seen
Schwierigkeit 2/5 Ein halber Tag Anfängerfreundlichkeit 86/100
-
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 75/100
apache/flink-agents#1156 ·
-
[source-shopify] FAILED bulk operation without partialDataUrl is silently treated as successful Offenarea/connectors autoteam community connectors/source/shopify needs-triage team/use type/bug
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 84/100
-
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 70/100
-
Schwierigkeit 1/5 Unter einer Stunde Anfängerfreundlichkeit 85/100