conduktor.io ↗

KIP-1278 — Configurable Retry Mechanism for KafkaStatusBackingStore

Discussion Kafka 4.3 Connect

Adds configurable retry parameters (max retries, backoff, timeout) to KafkaStatusBackingStore in Kafka Connect for handling failures when writing connector and task status to the internal status topic. Currently, some write paths block indefinitely on broker unavailability while others silently drop status updates, making connector state persistence unreliable and unobservable during broker outages.

Details

AuthorSaid BOUDJELDA
StatusDiscussion
Kafka Version4.3
JIRAKAFKA-20113
WikiView on Apache Wiki
Created2026-02-02
Last Modified2026-02-03
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.