'Initialize a SubscriptionState instance
Keyword Arguments:
offset_reset_strategy: \'earliest\' or \'latest\', otherwise
exception will be raised when fetching an offset that is no
longer available. Default: \'earliest\''

def __init__(self, offset_reset_strategy='earliest'):

    try:
        offset_reset_strategy = getattr(OffsetResetStrategy, offset_reset_strategy.upper())
    except AttributeError:
        log.warning('Unrecognized    offset_reset_strategy,    using    NONE')
        offset_reset_strategy = OffsetResetStrategy.NONE
    self._default_offset_reset_strategy = offset_reset_strategy
    self.subscription = None
    self.subscribed_pattern = None
    self._group_subscription = set()
    self._user_assignment = set()
    self.assignment = dict()
    self.needs_partition_assignment = False
    self.listener = None
    self.needs_fetch_committed_offsets = True
