def seek_to(topic, partition, offset)
      @processed_offsets[topic] ||= {}
      @processed_offsets[topic][partition] = offset

      @fetcher.seek(topic, partition, offset)
    end
def seek_to(topic, partition, offset)
      @processed_offsets[topic] ||= {}
      @processed_offsets[topic][partition] = offset

      @fetcher.seek(topic, partition, offset)
    end
Move the consumer's position in the partition to the specified offset.

 @param topic [String] the name of the topic.
 @param partition [Integer] the partition number.
 @param offset [Integer] the offset that the consumer position should be moved to.
 @return [nil]