def seek_to_default(topic, partition)
      # Remove any cached offset, in case things have changed broker-side.
      clear_resolved_offset(topic)

      offset = resolve_offset(topic, partition)

      seek_to(topic, partition, offset)
    end
def seek_to_default(topic, partition)
      # Remove any cached offset, in case things have changed broker-side.
      clear_resolved_offset(topic)

      offset = resolve_offset(topic, partition)

      seek_to(topic, partition, offset)
    end
Move the consumer's position in the partition back to the configured default
 offset, either the first or latest in the partition.

 @param topic [String] the name of the topic.
 @param partition [Integer] the partition number.
 @return [nil]