我已经在msk上创建了一个kafka集群，现在我正在尝试用python连接到集群。
我写了一个简短的代码：

from kafka import KafkaProducer
import json

producer = KafkaProducer(
    bootstrap_servers=['host1:9092', 'host2:9092'],
    value_serializer=lambda x: json.dumps(x).encode('utf-8'),
    api_version=(2, 4, 1)
)

producer.send('test', value={'hello':'world'})

问题是每次运行它时都会出现以下错误：

KafkaTimeoutError: Failed to update metadata after 60.0 secs.

我认为这可能与Kafka创建主题有关，所以我在配置中添加了这一行。

auto.create.topics.enable=true

但我还是犯了同样的错误。
这是我的完整配置文件：

default.replication.factor=3
min.insync.replicas=2
num.io.threads=8
num.network.threads=5
num.partitions=1
num.replica.fetchers=2
socket.request.max.bytes=104857600
unclean.leader.election.enable=true
auto.create.topics.enable=true
zookeeper.connection.timeout.ms=5000

我错过了什么？我在某个地方读到可能与ssl身份验证有关的内容，但在任何步骤中，都没有任何.pem文件、.ca文件或类似文件。