feat: allow StreamConsumer to start at "earliest"/"latest" offset

This is required to provide a race-free way to start at the earliest or
latest offset, because fetching the offset and then creating a stream
might fail because in the meantime the Kafka retention policy might
already have removed the offsets in question.

Author: crepererum