def highwater(self, partition):
        if not isinstance(partition, TopicPartition):
            raise TypeError('partition must be a TopicPartition namedtuple')
        assert self._subscription.is_assigned(partition), 'Partition is not assigned'
        return self._subscription.assignment[partition].highwater
Last known highwater offset for a partition
dataset/ETHPy150Open dpkp/kafka-python/kafka/consumer/group.py/KafkaConsumer.highwater