具有 kerberos 身份验证的 Kafka 控制台使用者

Question

如何使用来自 Kerberos 授权的 kafka（版本 0.10）服务器的已发布消息，因为正在使用身份验证密钥表文件。

我尝试使用以下命令，但没有显示输出。

bin/kafka-console-consumer.sh --bootstrap-server ：9092 --topic --from-start

Answer 1

启用Kerberos的集群有时会带来一些棘手的挑战。我不得不自己处理一些。

如果Kafka集群启用了Kerberos，则需要提供jaas。conf文件中的Kerberos详细信息。尝试以下步骤（它们对我有效）：

1. 创建jaas。conf文件，内容如下：

KafkaClient {
com.sun.security.auth.module.Krb5LoginModule required
useKeyTab=true
keyTab="<path-to-the-keytab-file>"
principal="<kafka-principal>";
};

注意：我假设已经创建了 Kafka 主体和关联的密钥表。如果没有，则需要先创建这些。

security.protocol=SASL_PLAINTEXT
sasl.kerberos.service.name=kafka

$export KAFKA_OPTS="-Djava.security.auth.login.config=<path-to-jaas.conf>"

$ kafka-console-consumer --topic <topic-name> --from-beginning 
--bootstrap-server <anybroker>:9092 --consumer.config <consumer.properties>

编辑-步骤3和4可以合并，以防优先选择将它们作为一个命令保留在命令历史记录中。

我希望这能有所帮助。