...

PULL REQUEST: https://github.com/apache/kafka/pull/5149 (WIP)

Motivation

In ~In order to use Kafka as the message broker within an Event Source architecture, it becomes essential that Kafka is able to reconstruct the current state of the events in a "most recent snapshot" approach.

...

The issue then occurs when the insertion order is not guaranteed, which causes the log compaction to keep the wrong state. This can be easily replicated when using a multi-threaded (or simply multiple) producer(s), or when sending the events asynchronously.~

Public Interfaces

There are no changes to the public interfaces. 

...