现在我正在制作一个 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 来创建用户?什么是最好的解决方案?