我需要开发一个 Python 程序来充当 Kafka 消费者并在此基础上进行一些处理。我使用了kafka-python,它在本地测试中做得很好。
但是,我的生产环境 (RHEL7) 需要 Kerberos 身份验证。Keytab 文件将用于此目的。
我找不到使用 kafka-python 引用此 Keytab 文件的方法(例如:通过在 Java Kafka Consumer 中配置 Jaas 配置文件)。
我找到了confluent-kafka-python,它似乎支持通过 Keytab 文件进行 Kerberos 身份验证。
另外,我读到如果 Java 进程处理 Kerberos 身份验证,可以使用 kafka-python。
哪种方法会是更好的解决方案?