lib/rdkafka/consumer.rb
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]
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.
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 .
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.
Return the current committed offset per partition for this consumer group .
None
TopicPartitionList
[RdkafkaError] When getting the committed positions fails.
[ RdkafkaError ] When getting the committed positions fails .
list
The topic with partitions to get the offsets for or nil to use the current subscription.
The topic with partitions to get the offsets for or nil to use the current subscription .
timeout_ms
The timeout for fetching this information.
The timeout for fetching this information .