kafka

Documentation

Index

• Variables
• 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
  • 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)

Variables

var AWSSASLFromConfigFn = notImportedAWSFn

AWSSASLFromConfigFn is populated with the child `aws` package when imported.

var (
	ErrUnsupportedSASLMechanism = errors.New("unsupported SASL mechanism")
)

SASL specific error types.

var SHA256 scram.HashGeneratorFcn = sha256.New

SHA256 generates the SHA256 hash

var SHA512 scram.HashGeneratorFcn = sha512.New

SHA512 generates the SHA512 hash

Functions

func ApplySASLConfig

func ApplySASLConfig(s ksasl.Config, mgr bundle.NewManagement, conf *sarama.Config) error

ApplySASLConfig applies a SASL config to a sarama config.

func NewKafkaWriter

func NewKafkaWriter(conf output.KafkaConfig, mgr bundle.NewManagement) (output.AsyncSink, error)

NewKafkaWriter returns a kafka writer.

Types

type XDGSCRAMClient

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

XDGSCRAMClient represents struct to XDG Scram client to initialize conversation

func (*XDGSCRAMClient) Begin

func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)

Begin initializes new client and conversation to securely transmit the provided credentials to Kafka

func (*XDGSCRAMClient) Done

func (x *XDGSCRAMClient) Done() bool

Done returns true if the conversation is completed or has errored.

func (*XDGSCRAMClient) Step

func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)

Step takes a string provided from a server (or just an empty string for the very first conversation step) and attempts to move the authentication conversation forward