':param consumer: an instance of `SimpleConsumer`'

def __init__(self, consumer):

    self.consumer = consumer
    self.initial_offsets = None
    self.high_water_mark = None
    self.logger = getLogger('kafka.context')
