c# - 为什么我刚开始在 Kafka 上使用 Confluent 为 .Net Consumer 获取“组授权失败”

Question

我有一个已经工作了几个月的 Kafka 消费者，但现在我收到以下信息： 经纪人：组授权失败

导致此错误的环境可能发生了什么变化？

GroupId 看起来是任何 Kafka 消费者的必填字段，所以我不知道发生了什么。我正在使用 Confluent.Kafka 1.3.0

标签： c#apache-kafkaconfluent-platform

Answer 1

我有同样的问题，Mário Meyrelles 的评论帮助了我。

props.put(StreamsConfig.APPLICATION_ID_CONFIG, "your-name-of-application-here");

这家伙需要有一个起始前缀，没有它是不允许的。