Searched refs:_auto_commit (Results 1 – 5 of 5) sorted by relevance
233 self._auto_commit()293 self._auto_commit()
300 self._auto_commit()334 self._auto_commit()
172 def _auto_commit(self): member in Consumer
105 defp need_commit?(fetch_response, _auto_commit)110 defp need_commit?(%{message_set: []}, _auto_commit), do: false
480 self._auto_commit = it_util.variant_to_value(482 if self._auto_commit is None:486 if self._auto_commit is None:487 self._auto_commit = it_util.variant_to_value(2243 if mode == self._auto_commit:2245 self._auto_commit = mode2255 return self._auto_commit2720 self._auto_commit)3905 if self._auto_commit:3914 if self._auto_commit:[all …]