AIOKafkaProducer failed to produce message with headers about aiokafka HOT 3 CLOSED

async def produce(self, message, topic, headers=None):
        try:
            logger.info(
                f"Sending message {message} with headers {headers} to topic {topic} with producer {self.producer}")
            await self.producer.send_and_wait(topic=topic, value=message, headers=headers)
            logger.info(
                f"Successfully produced message to topic '{topic}': {message}")
        except Exception as e:
            logger.error(f"Failed to produce message: {e}")
            raise