我正在尝试创建使用者,但出现错误“未能创建使用者:没有sasl机制的提供程序gssapi:使用libsasl2或openssl支持重新编译librdkafka。当前构建选项:普通sasl\u scram oauthbearer”。其中,在consumer中
config := &kafka.ConfigMap{
"metadata.broker.list": cfg.BrokerHostEndpoint,
"security.protocol": "SASL_PLAINTEXT",
"sasl.kerberos.service.name": "kafka",
"group.id": cfg.ConsumeTopic,
"auto.offset.reset": "earliest",
"go.application.rebalance.enable": true,
"go.events.channel.enable": true,
}
暂无答案!
目前还没有任何答案,快来回答吧!