group认证失败 - Githubissues

childe / healer

golang lib for kafka

22 stars 18 forks source link

group认证失败 #7

Closed guobinchn closed 5 years ago

guobinchn commented 5 years ago

在使用gohangout时，启动服务后日志报如下大量错误： I0103 16:49:58.393766 136330 group_consumer.go:167] try to join group xxxx I0103 16:49:58.393936 136330 group_consumer.go:190] join xxxx error: Not authorized to access group: Group authorization failed.

我的配置如下： inputs:

Kafka: codec: json topic: nginxlog: 1 consumer_settings: bootstrap.servers: "1.1.1.1:9092" group.id: xxxx client.id: nginxlogabc FromBeginning: true

childe commented 5 years ago

@guobinchn 先问一下, 你们是用的哪一种SASL? 一共有下面四种方式.

GSSAPI (Kerberos), PLAIN, SCRAM or OAUTHBEARER

guobinchn commented 5 years ago

我们目前采用的PLAIN方式。

childe commented 5 years ago

截止到 fb223075244fe1ff68184c0e035f8f43af8e2f24 , 已经添加了plain的认证. (tools里面几个自带的工具还没来得及添加, 但不影响做为库使用了.