Versions Compared

Key

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

...

This should have the latest committed off set of each task assigned to the client. Each poll will update this. The offsets committed by the task manger will be saved. Each time a new commit is made the map containing the offsets will update. When committedOffsets() is called then it will return this map.

isTaskIdling

If a task assigned to this instance is intentionally not pulling because it is idling this method will report that

...