When the offset retrieved from initializePartition in offsetManager, is very far off from the currently available offset, the consumePartition call will return a sarama.ErrOffsetOutOfRange error.
When the offset retrieved from initializePartition in offsetManager,
is very far off from the currently available offset, the consumePartition
call will return a sarama.ErrOffsetOutOfRange error.

This change just adjust the offset to either offsetOldest or offsetNewest, based on
what was specified in the sarama.Config and retries the call.

gcnonato/kafka,topfreegames/kafka,winlinvip/kafka-1,ORBAT/kafka,xlvector/kafka,datajet-io/kafka,clessor/kafka,yejingx/kafka,ChannelMeter/kafka,saleswise/kafka,wvanbergen/kafka,skyportsystems/kafka-2,bhirbec/kafka,kmiku7/kafka