epam/epam-kafka

External offsets storage should support AutoOffsetReset

Closed this issue · 0 comments

Ignore consumer group internal storage offset value if external or combined storage used by subscription.

As Is: value will be taken from internal storage if exists, otherwise will be resolved using AutoOffsetReset config value.
To Be: value should be resolved using AutoOffsetReset config, value from internal storage should be ignored.