使用Python

问题描述 投票:0回答:1

我们正在尝试使用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客户端无法正确连接。
python amazon-web-services apache-kafka aws-msk
1个回答
0
投票
此外,请检查您的SSL配置 - 也许TLS或丢失证书存在问题吗?尝试使用security_protocol =“ sasl_plaintext”或“违法”来运行它,只是查看连接是否有效。

参考:

aws MSK身份验证指南

© www.soinside.com 2019 - 2024. All rights reserved.