conduktor.io ↗

KIP-1339 — Make KafkaConfigBackingStore read_write_total_timeout configurable

Discussion Connect

Adds the Kafka Connect DistributedConfig property config.storage.kafka.store.read.write.total.timeout.ms (default 30000) so operators can tune KafkaConfigBackingStore's synchronous write-then-read-back timeout instead of relying on the hardcoded READ_WRITE_TOTAL_TIMEOUT_MS constant. The fixed 30-second bound causes ConnectException on high-load or unstable-network clusters and on workers replaying a large compacted single-partition config topic for thousands of connector tasks.

Details

AuthorHenry Cai
StatusDiscussion
WikiView on Apache Wiki
Created2026-05-14
Last Modified2026-05-15
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.