ciena / afkak

Kafka client written in Twisted Python
Apache License 2.0
32 stars 22 forks source link

The OFFSET_LATEST for auto_offset_reset was not getting honored for non-existent consumer group IDs #114

Closed phudgins-ciena closed 4 years ago

phudgins-ciena commented 4 years ago

The OFFSET_LATEST for auto_offset_reset was not getting honored for non-existent consumer group IDs. It was always setting it to OFFSET_EARLIEST when the consumer group was not found. This change will check for a passed-in value to use in this case. The default, when None is passed in, is to set it to OFFSET_EARLIEST.