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

Abierto

#354 abierto el 14/9/2020 6 comentarios 5 reacciones 0 asignados Ver en GitHub

Nadie ha tomado este issue todavía.

Evaluación

Dificultad: 4/5
Tiempo estimado: 3-5 días
Aptitud para principiantes: 35/100

Tipo de issue: Nueva funcionalidad
Claridad: Bastante claro
Estado de actividad: Estancado
Stack tecnológico: java, kafka, sql
Área: stream-processing

Línea de trabajo

En el issue no se nombra ningún archivo, prueba ni punto de entrada. Empieza por localizar la configuración de la fuente Kafka de FlinkStreamSQL 1.10 y su gestión del modo de offset, y compárala después con el comportamiento de group-offsets de Flink; la tarea estará terminada cuando una groupId configurada reanude desde los offsets de grupo confirmados y conserve el comportamiento inicial latest o earliest para un grupo nuevo.

Escrito por el modelo de indexación a partir del texto del issue.

Descripción

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

Lenguaje dominante: Java
Estrellas: 2k
Forks: 913
Métricas de merge de PR: Sin PR fusionados en 30 d

Guía de contribución

No hay ninguna guía de contribución indexada para este repositorio

Primeros pasos

Lee el issue completo y luego la guía de contribución del proyecto.
Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
Haz un fork del repositorio y trabaja en una rama.
Abre un pull request que haga referencia al número del issue.

Más de DTStack/flinkStreamSQL

Flink SQL 使用滚动窗口，能不能获取到延迟数据，跟datastream一样，可以放到侧输出里面 Abierto

Dificultad 5/5 Más de una semana Aptitud para principiantes 20/100

DTStack/flinkStreamSQL#467 · 1 comentario · Abierto el 27/9/2024
这个如何引入使用flink-connector-hive啊 Abierto

Dificultad 4/5 3-5 días Aptitud para principiantes 25/100

DTStack/flinkStreamSQL#437 · 3 comentarios · Abierto el 25/2/2022
kudu sink writemode参数没填写报NULLPointerException Abierto

Dificultad 3/5 1-2 días Aptitud para principiantes 38/100

DTStack/flinkStreamSQL#432 · 1 comentario · Abierto el 16/11/2021
新版FlinkStreamSQL已经融合进FlinkX项目 Abierto

Dificultad 5/5 Más de una semana Aptitud para principiantes 15/100

DTStack/flinkStreamSQL#431 · Abierto el 1/11/2021
有无对sql 语法校验的方法 Abierto

Dificultad 5/5 Más de una semana Aptitud para principiantes 15/100

DTStack/flinkStreamSQL#430 · 1 comentario · Abierto el 8/10/2021

Todos los issues de DTStack/flinkStreamSQL

Issues similares

[BUG] Unified agent on Bedrock Converse with no tools is unusable: an empty `toolConfig` is emitted and Bedrock rejects the request Abierto

bug untriaged

Dificultad 2/5 1-3 horas Aptitud para principiantes 84/100

opensearch-project/ml-commons#5094 · Abierto el 22/9/2026
[Bug report] iceberg rest server load_table with refs fails precondition check "Cannot set metadata location with changes to table metadata: %s changes" for snapshots with statistics Abierto

bug

Dificultad 2/5 1-3 horas Aptitud para principiantes 85/100

apache/gravitino#13452 · Abierto el 22/9/2026
Support Test Project Creation for New Projects Abierto

emitter:client:csharp feature

Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100

microsoft/typespec#12027 · 1 comentario · 1 reacción · Abierto el 22/9/2026
Job worker stops polling silently when a poll throws an Error Abierto

affects/8.10 affects/8.9 component/clients kind/bug likelihood/mid severity/mid

Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100

camunda/camunda#63825 · Abierto el 22/9/2026
Two open-case totals on one screen: the Programs tile says 15,858 and the nav badge says 15,868 Abierto

bug frontend maui-pilot

Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100

Taleef7/workwell#651 · 1 comentario · Abierto el 22/9/2026

Más issues de Java