Versions Compared

Old Version 17

changes.mady.by.user Philip Nee

Saved on

compared with

New Version 18

changes.mady.by.user Philip Nee

Saved on

Key

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

...

  • Update Java Docs

  • API signatures will remain the same

  • API returned exceptions can be a little bit different.  See wakeupException() sectionException thrown will be different.

Summary

This document highlights our effort to refactor the threading model of the KafkaConsumer, and the purpose of this refactor is to address issues and shortcomings we’ve encountered in the past years, such as increasing code complexity, lock and race conditions, and the coupling between the client poll and the rebalance progress.

...