docstr: Retrieves the last successfully committed Kafka offset of the
  underlying KafkaDatasource connection.
  
  Parameters
  ----------
  partitions : list,
      Topic/Partition instances that specify the TOPPAR
      instances the offsets should be retrieved for
  timeout : int, default 10000,
      Max time to wait on the response from
      the Kafka broker in milliseconds
  
  Returns
  -------
  tuple
      Tuple of ck.TopicPartition objects
docstr_tok: ["Retrieves","the","last","successfully","committed","Kafka","offset","of","the","underlying","KafkaDatasource","connection",".","Parameters","--","--","--","--","--","partitions",":","list",",","Topic\/Partition","instances","that","specify","the","TOPPAR","instances","the","offsets","should","be","retrieved","for","timeout",":","int",",","default","10000",",","Max","time","to","wait","on","the","response","from","the","Kafka","broker","in","milliseconds","Returns","--","--","--","-","tuple","Tuple","of","ck.TopicPartition","objects"]
code: def committed(self, partitions, timeout=10000):
      """
      Retrieves the last successfully committed Kafka offset of the
      underlying KafkaDatasource connection.
  
      Parameters
      ----------
      partitions : list,
          Topic/Partition instances that specify the TOPPAR
          instances the offsets should be retrieved for
      timeout : int, default 10000,
          Max time to wait on the response from
          the Kafka broker in milliseconds
  
      Returns
      -------
      tuple
          Tuple of ck.TopicPartition objects
      """
  
      toppars = [
          ck.TopicPartition(
              part.topic,
              part.partition,
              self.kafka_meta_client.get_committed_offset(
                  part.topic.encode(), part.partition
              ),
          )
          for part in partitions
      ]
  
      return toppars
  
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 3 for calling the Consumer obj's underlying member method code with example usage: obj.committed(partitions, timeout) and returns: toppars