my code is like this: while True: producer = KafkaProducer(bootstrap_servers=KAFKA_SERVER) producer.send('test', b'xxx') producer.close() it will cause a error like bellow: error: [Errono 9] Bad file descriptor point to the line `if self._wake_w.send(b'x') !=1` in the client_async.py