In an effort to limit traffic to the broker, I'm just keeping track of the keys that have been modified since the last flush.
As you'll see in the Store, when we do a flush, *then* we send the most recent state for all these keys to the record collector. In the long run, I'd like to do some lower-level optimization to support compacting the Producer's buffer for compacted topics, in which case we could drop this optimization here. But it seemed prudent, given the team's concerns about the performance impact of the buffer's changelog. [ Full content available at: https://github.com/apache/kafka/pull/5724 ] This message was relayed via gitbox.apache.org for [email protected]
