class_docstr: Manage the kafka network protocol
  
  Use an instance of KafkaProtocol to manage bytes send/recv'd
  from a network socket to a broker.
  
  Arguments:
      client_id (str): identifier string to be included in each request
      api_version (tuple): Optional tuple to specify api_version to use.
          Currently only used to check for 0.8.2 protocol quirks, but
          may be used for more in the future.
class_docstr_tok: ["Manage","the","kafka","network","protocol","Use","an","instance","of","KafkaProtocol","to","manage","bytes","send\/recv'd","from","a","network","socket","to","a","broker",".","Arguments",":","client_id","(","str",")",":","identifier","string","to","be","included","in","each","request","api_version","(","tuple",")",":","Optional","tuple","to","specify","api_version","to","use",".","Currently","only","used","to","check","for","0.8.2","protocol","quirks",",","but","may","be","used","for","more","in","the","future","."]
code: def _reset_buffer(self):
      self._receiving = False
      self._header.seek(0)
      self._rbuffer = None
  
file_path: kafka-python/kafka/protocol/parser.py
imports: from __future__ import absolute_import
  import collections
  import logging
  import kafka.errors
  from kafka.protocol.commit import GroupCoordinatorResponse
  from kafka.protocol.frame import KafkaBytes
  from kafka.protocol.types import Int32, TaggedFields
  from kafka.version import __version__
label_desc: Use image node_id 8 for calling the KafkaProtocol obj's underlying member method code with example usage: obj._reset_buffer() without return types