Versions in this module Expand all Collapse all v4 v4.14.1 Apr 26, 2023 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 ApplySASLConfig(s ksasl.Config, mgr bundle.NewManagement, conf *sarama.Config) error + func NewKafkaWriter(conf output.KafkaConfig, mgr bundle.NewManagement) (output.AsyncSink, error) + 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) Other modules containing this package github.com/dafanshu/benthos/v3