Versions Compared

Key

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

...

One of the main reason we are refactoring the KafkaConsumer is to satisfy the requirements of the new rebalance protocol introduced in KIP-848; however, we will make the framework as plugable as possible so that we can adpot the new API, as well as the old consumer protocol.  Here, we focus on the new protocol as it is the focus, and will expand later.

The important components we have here are:

...