我正在尝试为kafka（kerberos）开发spring boot中的consumer类。我根据gary建议的kerberos设置进行了必要的更改（密钥库格式无效，引导代理已断开连接），结果出现以下错误。我可以在本地用相同的keytab/jks文件设置kafka集群。
Failed to start bean 'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry'; nested exception is org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
Caused by: org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
Caused by: org.apache.kafka.common.KafkaException: javax.security.auth.login.LoginException: Unable to obtain password from user
1条答案
按热度按时间4jb9z9bj1#
大多数情况下，上述错误是由于keytab损坏或您的keytab上的权限不正确造成的。
一定要有
chmod 400密钥选项卡上的权限做一个
kinit并检查您的密钥选项卡是否有效。如果您需要更多帮助，请张贴您的代码。