def committed(list=nil, timeout_ms=1200)
      if list.nil?
        list = assignment
      elsif !list.is_a?(TopicPartitionList)
        raise TypeError.new("list has to be nil or a TopicPartitionList")
      end
      tpl = list.to_native_tpl
      response = Rdkafka::Bindings.rd_kafka_committed(@native_kafka, tpl, timeout_ms)
      if response != 0
        raise Rdkafka::RdkafkaError.new(response)
      end
      TopicPartitionList.from_native_tpl(tpl)
    end
def committed(list=nil, timeout_ms=1200)
      if list.nil?
        list = assignment
      elsif !list.is_a?(TopicPartitionList)
        raise TypeError.new("list has to be nil or a TopicPartitionList")
      end
      tpl = list.to_native_tpl
      response = Rdkafka::Bindings.rd_kafka_committed(@native_kafka, tpl, timeout_ms)
      if response != 0
        raise Rdkafka::RdkafkaError.new(response)
      end
      TopicPartitionList.from_native_tpl(tpl)
    end
Return the current committed offset per partition for this consumer group.
 The offset field of each requested partition will either be set to stored offset or to -1001 in case there was no stored offset for that partition.

 @param list [TopicPartitionList, nil] The topic with partitions to get the offsets for or nil to use the current subscription.
 @param timeout_ms [Integer] The timeout for fetching this information.

 @raise [RdkafkaError] When getting the committed positions fails.

 @return [TopicPartitionList]