docstr: 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
docstr_tok: ["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"]
code: 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
          )
  
file_path: cudf/python/custreamz/custreamz/kafka.py
imports: import confluent_kafka
  from cudf_kafka._lib.kafka import KafkaDatasource
  import cudf
label_desc: Use image node_id 5 for calling the Consumer obj's underlying member method code with example usage: obj.commit(offsets, asynchronous) without return types