connectors: preserve failed records throughout the sink pipeline
Los mantenedores suelen responder en 1 día
Evaluación
- Dificultad
- 5/5
- Tiempo estimado
- Más de una semana
- Aptitud para principiantes
- 35/100
- Tipo de issue
- Nueva funcionalidad
- Claridad
- Bastante claro
- Estado de actividad
- Activo
- Stack tecnológico
- rust
- Área
- stream-processing
Línea de trabajo
Start by tracing the connector sink pipeline through decoding, transformation, serialization, and delivery, then read the accounting introduced by #4152 alongside #4233 and #4234. Done means stage failures, filtering, plugin retries, and dead-letter delivery remain distinguishable, while checkpoints and destination results preserve unresolved records correctly; tests must cover failures at each stage.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
Parent tracker: #4232.
Carry record outcomes through decoding, transformation, serialization, and sink delivery so that a successful call for the remaining records cannot silently acknowledge records dropped earlier in the pipeline.
Acceptance criteria:
- Unexpected failures leave the affected source records unresolved and block checkpoints from passing them.
- Configured filtering is represented and counted separately from errors.
- Error information crosses the plugin boundary without collapsing every failure into an indistinguishable status.
- Retry ownership and limits are explicit, including retries already performed by plugins. Exhaustion pauses or stops affected work with an actionable error and preserves replay.
- Failure handling bounds pending work and does not abandon records already covered by a checkpoint.
- Any supported dead-letter policy confirms delivery to that destination before resolving the source record. Without such a policy, permanent record failures remain visible and unresolved.
- Tests exercise failures at each stage and verify the saved checkpoint and destination results.
Depends on #4233 and uses #4234. Extend the accounting introduced by #4152 while preserving the original input record's outcome.
- Lenguaje dominante
- Rust
- Estrellas
- 5.2k
- Forks
- 502
- Merge medio
- 3 d 3 h
- PR fusionados (30 d)
- 163
Preparar el entorno
Inicia el contenedor de desarrollo del proyecto en tu navegador, con tu propia cuenta de GitHub.
- Incluye un Dockerfile o un archivo de Docker Compose
- Tiene una plantilla de pull request
- Leer la guía de contribución
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 apache/iggy
-
Go examples: add a message envelope producer and consumerPosiblemente ocupada @ThunderGod77 la tomó hace 4 días. Abiertogo good first issue
Dificultad 2/5 1-3 horas Aptitud para principiantes 82/100
apache/iggy#4694 · 3 comentarios · 1 asignado ·
Los mantenedores suelen responder en 1 día
-
HTTP client treats a consumer group as a plain consumerPosiblemente ocupada @mohitduhan19 la tomó hace 22 días. Abiertobug rust server
Dificultad 2/5 1-3 horas Aptitud para principiantes 75/100
apache/iggy#4408 · 2 comentarios ·
Los mantenedores suelen responder en 1 día
-
Add the fail-fast connection option to the Rust and Python quick-startsPosiblemente ocupada @QIW9 la tomó hace 9 días. Abiertodocs good first issue
Dificultad 1/5 1-3 horas Aptitud para principiantes 92/100
apache/iggy#4261 · 3 comentarios ·
Los mantenedores suelen responder en 1 día
-
ResourceNotFound from the binary protocol prints an empty keyPosiblemente ocupada @xalestar la tomó hoy. Abiertoapi python rust
apache/iggy#4767 · 2 comentarios · 1 asignado ·
Los mantenedores suelen responder en 1 día
-
Node SDK: send accepts malformed user headers that fail during pollingPosiblemente ocupada @Subham-KRLX la tomó hace 2 días. Abiertobug good first issue javascript
apache/iggy#4750 · 3 comentarios · 1 asignado ·
Los mantenedores suelen responder en 1 día
Todos los issues de apache/iggy
Issues similares
-
bug i18n priority: medium ui
Dificultad 2/5 1-3 horas Aptitud para principiantes 65/100
storytold/craft-anything#983 · 1 comentario ·
Los mantenedores suelen responder en 1 día
-
`swf` upgrade to 0.4.0Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 66/100
Dinnerbone/Rascal#91 · 2 reacciones ·
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 76/100
higress-group/HiRoute#405 ·
Los mantenedores suelen responder en 1 día
-
rust_analyzer flycheck: no CLI way to enable clippy from `check.overrideCommand`Posiblemente ocupada @TrapsterDK la tomó hoy. Abiertoneeds-triage
Dificultad 2/5 1-3 horas Aptitud para principiantes 77/100
bazelbuild/rules_rust#4392 ·
Los mantenedores suelen responder en 2 días
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
Los mantenedores suelen responder en 1 día