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
Authorization and Proxy-Authorization headers are always forced to be
dataset/ETHPy150Open dpkp/kafka-python/kafka/consumer/group.py/KafkaConsumer.highwater--crossover with--dataset/ETHPy150Open python-hyper/hyper-h2/test/test_header_indexing.py/TestSecureHeaders.test_authorization_headers_never_indexed_push