如何在python中使用keytab连接kafka消费者主题

编程问答 2022-05-31

问题描述

我是 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，而是找到一种方法来传递 keytab 文件和主体以在身份验证过程中使用并从 kafka 主题中读取数据。 （如果可能？）

但不确定，KafkaConsumer 的哪个参数持有密钥表文件。

请提出更好的方法？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

kafka-consumer-apikerberoskeytabpython