Versions Compared

Old Version 10

changes.mady.by.user PoAn Yang

Saved on

compared with

New Version 11

changes.mady.by.user PoAn Yang

Saved on

Key

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

...

  • Backpressure: When an internal record buffer for a partition exceeds its capacity, Kafka Streams pauses that partition to prevent further fetching (StreamTask.addRecords()). It resumes the partition once the buffer drains below the threshold (StreamTask.resumePollingForPartitionsWithAvailableSpace()).
  • Rebalance lifecycle: After a rebalance, Kafka Streams pauses all partitions that are not yet owned by fully initialized tasks (TaskManager). Partitions are only resumed after state store restoration completes.
  • Changelog restore management: The StoreChangelogReader  pauses  pauses and resumes changelog partitions on the restore consumer depending on whether the corresponding tasks still exist.

...