def __enter__(self):
self.initial_offsets = dict(self.consumer.offsets)<EOL>self.high_water_mark = dict()<EOL>self.logger.debug("<STR_LIT>", self.initial_offsets)<EOL>return self<EOL>
Start a new context:

 -  Record the initial offsets for rollback
 -  Reset the high-water mark