我们正在尝试使用Python获取主题列表,但它返回空列表。
from kafka.admin import KafkaAdminClient
#configure Kafka client for SCRAM
client = KafkaAdminClient(
bootstrap_servers="b-2-public.url.url2.c3.kafka.eu-west-3.amazonaws.com:9196",
sasl_mechanism="SCRAM-SHA-512",
sasl_plain_username="user",
sasl_plain_password="pass",
security_protocol="SASL_SSL")
topics = client.list_topics()
print(topics)
我们能够使用Java检索Topis列表,但由于某些原因而不是在Python中。
我们使用Python 3.7,Kafka-Python2.0.2.任何想法?
首先,双检查您的配置。有时,即使是SCRAM身份验证中的一个小错误也会引起问题。由于Java能够获取主题列表,但Python却没有,因此可能是配置问题,或者Python Kafka客户端无法正确连接。
参考:
aws MSK身份验证指南