conduktor.io ↗

KIP-1118 — Add Deadlock Protection on Producer Network Thread

Accepted Kafka 4.1 Producer

Adds deadlock detection to `KafkaProducer` so that calling `Producer#flush()` from within a `send()` callback throws `KafkaException` instead of blocking indefinitely. Invoking `flush()` from the I/O thread that executes send callbacks creates an irresolvable circular wait, causing application hangs that are difficult to diagnose.

Details

AuthorTengYao Chi
StatusAccepted
Kafka Version4.1
JIRAKAFKA-10790
WikiView on Apache Wiki
Created2024-11-30
Last Modified2025-01-03
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.