我的 kafka 部署在 kubernetes 中，所以我转发了 9092 端口
kubectl port-forward -n kafka svc/kafka 9092
并尝试运行hello_world.py 但遇到异常
[2020-10-01 00:31:52,331] [3503] [错误] 无法连接到 id 为 0 的节点：[Errno -2] 名称或服务未知
[2020-10-01 00:31:52,341] [3503 ] [ERROR] [^Worker]: Error: ConnectionError('No connection to node with id 0',)
完整的堆栈跟踪：
Connected to pydev debugger (build 202.7319.64)
+ƒaµS† v1.11.0a1-----------------------------------------------------------------------+
| id | hello-world-alex |
| transport | [URL('kafka://localhost:9092')] |
| store | memory: |
| web | http://desktop-jd8f1bk:6066 |
| log | -stderr- (info) |
| pid | 3503 |
| hostname | DESKTOP-JD8F1BK |
| platform | CPython 3.6.9 (Linux x86_64) |
| drivers | |
| transport | aiokafka=1.1.6 |
| web | aiohttp=3.6.2 |
| datadir | /mnt/c/work/dev/project/python/faust/examples/hello-world-alex-data |
| appdir | /mnt/c/work/dev/project/python/faust/examples/hello-world-alex-data/v1 |
+-------------+------------------------------------------------------------------------+
[2020-10-01 00:31:51,923] [3503] [INFO] [^Worker]: Starting...
[2020-10-01 00:31:51,945] [3503] [INFO] [^-App]: Starting...
[2020-10-01 00:31:51,945] [3503] [INFO] [^--Monitor]: Starting...
[2020-10-01 00:31:51,946] [3503] [INFO] [^--Producer]: Starting...
[2020-10-01 00:31:51,947] [3503] [INFO] [^---ProducerBuffer]: Starting...
[2020-10-01 00:31:52,331] [3503] [ERROR] Unable connect to node with id 0: [Errno -2] Name or service not known
[2020-10-01 00:31:52,341] [3503] [ERROR] [^Worker]: Error: ConnectionError('No connection to node with id 0',)
Traceback (most recent call last):
File "/usr/local/lib/python3.6/dist-packages/mode/worker.py", line 273, in execute_from_commandline
self.loop.run_until_complete(self._starting_fut)
File "/usr/lib/python3.6/asyncio/base_events.py", line 484, in run_until_complete
return future.result()
File "/usr/local/lib/python3.6/dist-packages/mode/services.py", line 736, in start
await self._default_start()
File "/usr/local/lib/python3.6/dist-packages/mode/services.py", line 743, in _default_start
await self._actually_start()
File "/usr/local/lib/python3.6/dist-packages/mode/services.py", line 767, in _actually_start
await child.maybe_start()
File "/usr/local/lib/python3.6/dist-packages/mode/services.py", line 795, in maybe_start
await self.start()
File "/usr/local/lib/python3.6/dist-packages/mode/services.py", line 736, in start
await self._default_start()
File "/usr/local/lib/python3.6/dist-packages/mode/services.py", line 743, in _default_start
await self._actually_start()
File "/usr/local/lib/python3.6/dist-packages/mode/services.py", line 767, in _actually_start
await child.maybe_start()
File "/usr/local/lib/python3.6/dist-packages/mode/services.py", line 795, in maybe_start
await self.start()
File "/usr/local/lib/python3.6/dist-packages/mode/services.py", line 736, in start
await self._default_start()
File "/usr/local/lib/python3.6/dist-packages/mode/services.py", line 743, in _default_start
await self._actually_start()
File "/usr/local/lib/python3.6/dist-packages/mode/services.py", line 760, in _actually_start
await self.on_start()
File "/mnt/c/work/dev/project/python/faust/faust/transport/drivers/aiokafka.py", line 1022, in on_start
await producer.start()
File "/usr/local/lib/python3.6/dist-packages/aiokafka/producer/producer.py", line 178, in start
await self.client.bootstrap()
File "/usr/local/lib/python3.6/dist-packages/aiokafka/client.py", line 235, in bootstrap
self._api_version = await self.check_version()
File "/usr/local/lib/python3.6/dist-packages/aiokafka/client.py", line 533, in check_version
"No connection to node with id {}".format(node_id))
kafka.errors.ConnectionError: ConnectionError: No connection to node with id 0
[2020-10-01 00:31:52,354] [3503] [INFO] [^Worker]: Stopping...
[2020-10-01 00:31:52,355] [3503] [INFO] [^-App]: Stopping...
[2020-10-01 00:31:52,356] [3503] [INFO] [^-App]: Flush producer buffer...
[2020-10-01 00:31:52,357] [3503] [INFO] [^--TableManager]: Stopping...
[2020-10-01 00:31:52,358] [3503] [INFO] [^---Fetcher]: Stopping...
[2020-10-01 00:31:52,359] [3503] [INFO] [^---Conductor]: Stopping...
[2020-10-01 00:31:52,360] [3503] [INFO] [^--AgentManager]: Stopping...
[2020-10-01 00:31:52,361] [3503] [INFO] [^Agent: __main__.print_greetings]: Stopping...
[2020-10-01 00:31:52,362] [3503] [INFO] [^--ReplyConsumer]: Stopping...
[2020-10-01 00:31:52,363] [3503] [INFO] [^--LeaderAssignor]: Stopping...
[2020-10-01 00:31:52,364] [3503] [INFO] [^--Consumer]: Stopping...
[2020-10-01 00:31:52,367] [3503] [INFO] [^--Web]: Stopping...
[2020-10-01 00:31:52,368] [3503] [INFO] [^--CacheBackend]: Stopping...
[2020-10-01 00:31:52,369] [3503] [INFO] [^--Producer]: Stopping...
[2020-10-01 00:31:52,369] [3503] [INFO] [^---ProducerBuffer]: Stopping...
[2020-10-01 00:31:52,372] [3503] [INFO] [^--Monitor]: Stopping...
[2020-10-01 00:31:52,374] [3503] [INFO] [^Worker]: Gathering service tasks...
[2020-10-01 00:31:52,375] [3503] [INFO] [^Worker]: Gathering all futures...
[2020-10-01 00:31:54,404] [3503] [INFO] [^Worker]: Closing event loop
Process finished with exit code 1
你能解释一下，我应该解决什么问题
