0

现在我正在制作一个 kafka 服务代理,并希望在使用 golang 进行配置时创建一个新用户。我检查了 Go 的所有 kafka 库,但没有找到任何方法来创建用户(主体)。似乎 Shopify/Sarama 下面的两种方法可能是可行的,但我不知道如何使用它,也找不到示例代码。

//AlterConfigsRequest is an alter config request type
type AlterConfigsRequest struct {
    Resources    []*AlterConfigsResource
    ValidateOnly bool
}
//AlterConfigsResource is an alter config resource type
type AlterConfigsResource struct {
    Type          ConfigResourceType
    Name          string
    ConfigEntries map[string]*string
}

我想做的是: bin/kafka-configs.sh --zookeeper localhost:2181 --alter --add-config 'SCRAM-SHA-256=[iterations=8192,password=myusername-secret],SCRAM-SHA-512=[password=myusername-secret]' --entity-type users --entity-name myusername

是否可以调用 kafka-rest-api 来创建用户?什么是最好的解决方案?

4

0 回答 0