Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

The consumer (Fetcher) delays decompression until the records are returned to the user, but because of max.poll.records, it may end up holding onto the decompressed data from a single partition for a few iterations. Therefore buffer.memory is not a hard bound constraint on the consumer's memory usage as mentioned in the setting's description.

Similarly to KIP-72, metrics about the MemoryPool (usage, free space, etc) will be exposed by the Consumer

Compatibility, Deprecation, and Migration Plan

...