KIP-27 — Conditional Publish

Discussion ProducerBroker

Proposes a conditional-publish primitive where a producer attaches an expected offset to a message; the broker rejects the write if the partition's next offset does not match. Kafka's at-least-once delivery model makes it difficult to implement optimistic concurrency or prevent duplicate writes when multiple producers compete for the same partition or a producer retries after a network failure.

Details