def add_topic(self, topic):
        if topic not in self._topics_to_add:
            self._topics_to_add.add(topic)
            self.wakeup()
dataset/ETHPy150Open dpkp/kafka-python/kafka/producer/sender.py/Sender.add_topic/original