为什么我刚开始使用 Confluent for a .Net Consumer 在 Kafka 上获得 "Group authorization failed"
Why did I just start getting "Group authorization failed" on Kafka using Confluent for a .Net Consumer
我有一个已经工作了几个月的 Kafka 消费者,但现在我收到以下信息:
经纪人:群组授权失败
环境中可能发生了什么变化会导致此错误?
GroupId 看起来是任何 Kafka 消费者的必填字段,所以我不知道发生了什么。
我正在使用 Confluent.Kafka 1.3.0
我遇到了同样的问题,Mário Meyrelles 的评论帮助了我。
props.put(StreamsConfig.APPLICATION_ID_CONFIG, "your-name-of-application-here");
这家伙需要有一个起始前缀,没有它就不允许。
我发现了我的问题,但它可能不适用于其他人。
我在 VS.
中 running/debugging 时第一次看到这个错误
四处走动后发现,在我的环境中,即 Win10 上的 VS2017,Kafka 在幕后使用 Kerberos 获取执行用户的凭据,并传递这些凭据以验证对 Kafka 的访问。因此,在 Windows 10 环境中,这意味着 Kerberos 使用 Active Directory 并传递我的 AD id。
不,您不能更改和使用 Keytab 文件等替代方案。
所以底线是 Kafka 管理员对 Windows AD 组进行了一些更改,删除了我的 NTID。管理员试图仅通过系统 ID 来限制访问。发现后,我要求重新加入AD组,现在一切都很好。
我有一个已经工作了几个月的 Kafka 消费者,但现在我收到以下信息: 经纪人:群组授权失败
环境中可能发生了什么变化会导致此错误?
GroupId 看起来是任何 Kafka 消费者的必填字段,所以我不知道发生了什么。 我正在使用 Confluent.Kafka 1.3.0
我遇到了同样的问题,Mário Meyrelles 的评论帮助了我。
props.put(StreamsConfig.APPLICATION_ID_CONFIG, "your-name-of-application-here");
这家伙需要有一个起始前缀,没有它就不允许。
我发现了我的问题,但它可能不适用于其他人。 我在 VS.
中 running/debugging 时第一次看到这个错误四处走动后发现,在我的环境中,即 Win10 上的 VS2017,Kafka 在幕后使用 Kerberos 获取执行用户的凭据,并传递这些凭据以验证对 Kafka 的访问。因此,在 Windows 10 环境中,这意味着 Kerberos 使用 Active Directory 并传递我的 AD id。
不,您不能更改和使用 Keytab 文件等替代方案。
所以底线是 Kafka 管理员对 Windows AD 组进行了一些更改,删除了我的 NTID。管理员试图仅通过系统 ID 来限制访问。发现后,我要求重新加入AD组,现在一切都很好。