{"errorMessage": "[Errno 16] Device or resource busy", "errorType": "OSError", "requestId": "6b54e469-3e00-4e1d-a024-2169112ae444", "stackTrace": ["  File \"/var/task/lambda_function.py\", line 28, in lambda_handler\n    write_message(message)\n", "  File \"/var/task/lambda_function.py\", line 14, in write_message\n    producer = KafkaProducer(\n", "  File \"/opt/python/lib/python3.12/site-packages/kafka/producer/kafka.py\", line 383, in __init__\n    client = self.config['kafka_client'](\n", "  File \"/opt/python/lib/python3.12/site-packages/kafka/client_async.py\", line 234, in __init__\n    self.config['api_version'] = self.check_version(timeout=check_timeout)\n", "  File \"/opt/python/lib/python3.12/site-packages/kafka/client_async.py\", line 903, in check_version\n    self._maybe_connect(try_node)\n", "  File \"/opt/python/lib/python3.12/site-packages/kafka/client_async.py\", line 391, in _maybe_connect\n    conn.connect()\n", "  File \"/opt/python/lib/python3.12/site-packages/kafka/conn.py\", line 345, in connect\n    next_lookup = self._next_afi_sockaddr()\n", "  File \"/opt/python/lib/python3.12/site-packages/kafka/conn.py\", line 304, in _next_afi_sockaddr\n    if not self._dns_lookup():\n", "  File \"/opt/python/lib/python3.12/site-packages/kafka/conn.py\", line 295, in _dns_lookup\n    self._gai = dns_lookup(self.host, self.port, self.afi)\n", "  File \"/opt/python/lib/python3.12/site-packages/kafka/conn.py\", line 1273, in dns_lookup\n    socket.getaddrinfo(host, port, afi,\n", "  File \"/var/lang/lib/python3.12/socket.py\", line 978, in getaddrinfo\n    for res in _socket.getaddrinfo(host, port, family, type, proto, flags):\n"]}