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
| Author | Henry Cai |
| Status | Discussion |
| Wiki | View on Apache Wiki |
| Created | 2026-05-14 |
| Last Modified | 2026-05-15 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.