def add_header(self, key, value):
        self._extra_headers[key] = value
Stop the producer (async mode). Blocks until async thread completes.
dataset/ETHPy150Open datafolklabs/drest/drest/request.py/RequestHandler.add_header--crossover with--dataset/ETHPy150Open dpkp/kafka-python/kafka/producer/base.py/Producer.stop