Versions in this module Expand all Collapse all v4 v4.27.1 May 31, 2024 v4.27.0 May 31, 2024 Changes in this version + var AWSSASLFromConfigFn = notImportedAWSFn + var ErrUnsupportedSASLMechanism = errors.New("unsupported SASL mechanism") + var SHA256 scram.HashGeneratorFcn = sha256.New + var SHA512 scram.HashGeneratorFcn = sha512.New + func ApplySaramaSASLFromParsed(pConf *service.ParsedConfig, mgr *service.Resources, conf *sarama.Config) error + func NewKafkaWriterFromParsed(conf *service.ParsedConfig, mgr *service.Resources) (service.BatchOutput, error) + func OSKConfigSpec() *service.ConfigSpec + func SaramaSASLField() *service.ConfigField + type XDGSCRAMClient struct + func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) + func (x *XDGSCRAMClient) Done() bool + func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)
Go to main page