3

我是 Kafka 的新手，并尝试使用 python 从 kafka 消费者主题中读取消息。我正在使用下面的代码来阅读消息。

from kafka import KafkaConsumer

topic = 'topic'
bootstrap_servers = 'server'

consumer = KafkaConsumer(bootstrap_servers = [bootstrap_servers],
               auto_offset_reset = 'earliest',
               enable_auto_commit = True,
               security_protocol = 'SASL_PLAINTEXT',
               sasl_mechanism = 'GSSAPI',
               consumer_timeout_ms = 1000)

当我运行它时，收到错误消息“找不到 KfW 安装”并且无法连接 Kafka。为 Windows MSI 安装了 Kerberos 并重新运行，它能够建立连接。

但是，我试图避免在本地系统中安装 KfW，而是找到一种方法来传递密钥表文件和主体以在身份验证过程中使用并从 kafka 主题中读取数据。（如果它是可能的？）

但不确定，KafkaConsumer 的哪个参数包含 keytab 文件。

请建议任何更好的方法可用？

4

0 回答 0