connectors: preserve failed records throughout the sink pipeline
I maintainer di solito rispondono entro 1 giorno
Nessuno ha ancora preso questa issue.
Valutazione
- Difficoltà
- 5/5
- Tempo stimato
- Più di una settimana
- Idoneità per principianti
- 35/100
- Tipo di issue
- Funzionalità
- Chiarezza
- Abbastanza chiara
- Stato di attività
- Attiva
- Stack tecnologico
- rust
- Ambito
- stream-processing
Direzione di ricerca
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.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Descrizione
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.
- Lingua principale
- Rust
- Stelle
- 5.2k
- Fork
- 502
- Merge medio
- 3g 8h
- PR unite (30g)
- 146
Preparare l'ambiente
Avvia il container di sviluppo del progetto nel browser, con il tuo account GitHub.
- Include un Dockerfile o un file Docker Compose
- Ha un modello di pull request
- Leggi la guida per i contributori
Come iniziare
- Leggi tutta la issue e poi la guida ai contributi del progetto.
- Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
- Fai un fork del repository e lavora su un branch.
- Apri una pull request che faccia riferimento al numero della issue.
Altre issue di apache/iggy
-
Go examples: add a message envelope producer and consumerForse già presa @ThunderGod77 l’ha presa oggi. Apertago good first issue
Difficoltà 2/5 1-3 ore Idoneità per principianti 82/100
apache/iggy#4694 · 3 commenti · 1 assegnatario ·
I maintainer di solito rispondono entro 1 giorno
-
HTTP client treats a consumer group as a plain consumerForse già presa @mohitduhan19 l’ha presa 18 giorni fa. Apertabug rust server
Difficoltà 2/5 1-3 ore Idoneità per principianti 75/100
apache/iggy#4408 · 2 commenti ·
I maintainer di solito rispondono entro 1 giorno
-
Add the fail-fast connection option to the Rust and Python quick-startsForse già presa @QIW9 l’ha presa 6 giorni fa. Apertadocs good first issue
Difficoltà 1/5 1-3 ore Idoneità per principianti 92/100
apache/iggy#4261 · 3 commenti ·
I maintainer di solito rispondono entro 1 giorno
-
bug python sdk
Difficoltà 2/5 1-3 ore Idoneità per principianti 68/100
apache/iggy#3748 · 1 commento ·
I maintainer di solito rispondono entro 1 giorno
-
perf(cluster): reduce idle replica traffic caused by Commit heartbeatsForse già presa @mmmmxa l’ha presa oggi. Apertaapi cluster performance
apache/iggy#4707 · 1 assegnatario ·
I maintainer di solito rispondono entro 1 giorno
Issue simili
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 72/100
I maintainer di solito rispondono entro 1 giorno
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 82/100
hydro-project/hydro#3289 ·
I maintainer di solito rispondono entro 1 giorno
-
diagram-bug good first issue help wanted
Difficoltà 2/5 1-3 ore Idoneità per principianti 82/100
enhapu-afk/omaspec#4 ·
-
priority: low ☕️ type: bug 🐛
Difficoltà 2/5 1-3 ore Idoneità per principianti 62/100
I maintainer di solito rispondono entro 1 giorno
-
bug security
Difficoltà 2/5 1-3 ore Idoneità per principianti 70/100
I maintainer di solito rispondono entro 4 giorni