如何解决Kafkatimeouterror：在60.0秒后无法更新元数据？

Question

我正在尝试使用Kafka-Python向我的AWS MSK无服务器集群发送消息。 我已经通过以下本指南创建了MSK无服务器集群： https://docs.aws.amazon.com/msk/latest/developerguide/msk-serverless-produce-consume.html

我的群集处于活动状态，我在同一VPC和VPC和与我的集群相同的子网。我已经通过使用命令行（教程中的步骤5）创建了一个成功发送给它的主题和红色消息。

现在，我需要使用Python做同样的事情。因此，我尝试执行以下操作：

from kafka import KafkaProducer
cluster_endpoint = 'boot-name.c1.kafka-serverless.reagion-name.amazonaws.com:9098'
producer = KafkaProducer(security_protocol="SSL",bootstrap_servers=[cluster_endpoint])
producer.send('my-topic-name', "test message")

但是在这一点上，我收到

Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/home/ec2-user/.local/lib/python3.7/site-packages/kafka/producer/kafka.py", line 576, in send
    self._wait_on_metadata(topic, self.config['max_block_ms'] / 1000.0)
  File "/home/ec2-user/.local/lib/python3.7/site-packages/kafka/producer/kafka.py", line 703, in _wait_on_metadata
    "Failed to update metadata after %.1f secs." % (max_wait,))
kafka.errors.KafkaTimeoutError: KafkaTimeoutError: Failed to update metadata after 60.0 secs.

我注意到端口通常是 9091 或 9092 ，但是当我转到“查看客户端信息”时对于我的群集，我的端点是我在代码中使用 9098 端口号码所写的。

我在这里遵循不同的建议，但没有任何帮助。 这就是我尝试的：

• https://community.bitnami.com/t/kafka-producer termeTexecception-failed-failed-to-pate-metdate-metadata-after-6000000-ms/82159/6

丢失的？