def __init__(self, consumer):
        self.consumer = consumer
        self.initial_offsets = None
        self.high_water_mark = None
        self.logger = getLogger("kafka.context")
:param candidate_campaign_id:
dataset/ETHPy150Open dpkp/kafka-python/kafka/context.py/OffsetCommitContext.__init__--crossover with--dataset/ETHPy150Open wevoteeducation/WeVoteBase/position/views.py/assemble_candidate_campaign_stance_html