kafka

type Client struct {
	// contains filtered or unexported fields
}

type SimpleClientConfig struct {
	BootstrapServers string `json:"bootstrapservers"`
	ClientId         string `json:"clientid"`
	GroupId          string `json:"groupid"`
	ScramAuthType    string `json:"authtype"`
	ScramUsername    string `json:"username"`
	ScramPassword    string `json:"password"`
	UseSslTls        bool   `json:"usetls"`
}

type XDGSCRAMClient struct {
	*scram.Client
	*scram.ClientConversation
	scram.HashGeneratorFcn
}