docs: def set_last_position(self, last_position):
          """
          Called from the manager, it is in charge of updating the last position of data commited
          by the writer, in order to have resume support
          """
          last_position = last_position or {}
          last_position.setdefault('readed_streams', [])
          last_position.setdefault('stream_offset', {})
          self.last_position = last_position