parameters: (self, offsets=None, asynchronous=True)
docstring: Takes a list of ck.TopicPartition objects and commits their
          offset values to the KafkaDatasource connection
  
          Parameters
          ----------
          offsets : list,
              ck.TopicPartition objects containing the
              Topic/Partition/Offset values to be committed to the Kafka broker
          asynchronous : {{ True, False }}, default True,
              True to wait on
              Kafka broker response to commit request and False otherwise
docstring_summary: Takes a list of ck.TopicPartition objects and commits their
          offset values to the KafkaDatasource connection
docstring_tokens: Takes a list of ck . TopicPartition objects and commits their offset values to the KafkaDatasource connection
function: def commit(self, offsets=None, asynchronous=True):
  
          """
          Takes a list of ck.TopicPartition objects and commits their
          offset values to the KafkaDatasource connection
  
          Parameters
          ----------
          offsets : list,
              ck.TopicPartition objects containing the
              Topic/Partition/Offset values to be committed to the Kafka broker
          asynchronous : {{ True, False }}, default True,
              True to wait on
              Kafka broker response to commit request and False otherwise
          """
  
          for offs in offsets:
              self.kafka_meta_client.commit_offset(
                  offs.topic.encode(), offs.partition, offs.offset
              )
function_tokens: def commit ( self , offsets = None , asynchronous = True ) : for offs in offsets : self . kafka_meta_client . commit_offset ( offs . topic . encode ( ) , offs . partition , offs . offset )