This class is tracking state for all filtered batches. Earlier, all branches in `filterTo` were cluttered with logic to track state per batch and aggregating that over all the batches we have seen so far. With this class, we now only track per batch state and `FilteredBatchesMetadata` holds the aggregate. Cleaner separation and avoiding code repetition, mostly which also makes it easier to reason about which fields have / have not been initialized in a particular branch.
Two fields have been left out from here: `messagesRead` and `bytesRead`. Both these fields are aggregated for all the data we have seen so far, regardless of whether we end up filtering it or not. [ Full content available at: https://github.com/apache/kafka/pull/5623 ] This message was relayed via gitbox.apache.org for [email protected]
