def mark(self, partition, offset):
max_offset = max(offset + <NUM_LIT:1>, self.high_water_mark.get(partition, <NUM_LIT:0>))<EOL>self.logger.debug("<STR_LIT>",<EOL>{partition: max_offset})<EOL>self.high_water_mark[partition] = max_offset<EOL>
Set the high-water mark in the current context.

In order to know the current partition, it is helpful to initialize
the consumer to provide partition info via:

.. code:: python

    consumer.provide_partition_info()