Versions Compared

Key

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

...

With the introduction of this mode, the offset lag which results from a crash will be removed and any latency in terms of time that results would be negated (i.e. we continue processing as if the crash never happened). The user can use multiple threads of course to speed up processing of records to mitigate this lag, but this they would only resolve the problem to an extent. The user does not have access to critical information in Kafka internals (for example, when a missed heartbeat triggers a LeaveGroupRequest). So they the user are not in any position to exploit this information. Meanwhile, we can.

...