awsmsk

Documentation

Overview

Package msk implements the required IAM auth used by AWS' managed Kafka platform to be used with the Surama kafka producer.

Further details on how the SASL connector works can be viewed here:

https://github.com/aws/aws-msk-iam-auth#details

Index

• Constants
• Variables
• func NewIAMSASLClient(mskhostname, region, useragent string) sarama.SCRAMClient
• type IAMSASLClient
  • func (sc *IAMSASLClient) Begin(username, password, _ string) error
  • func (sc *IAMSASLClient) Done() bool
  • func (sc *IAMSASLClient) Step(challenge string) (string, error)

Constants

const (
	Mechanism = "AWS_MSK_IAM"
)

Variables

var (
	ErrFailedServerChallenge = errors.New("failed server challenge")
	ErrBadChallenge          = errors.New("invalid challenge data provided")
	ErrInvalidStateReached   = errors.New("invalid state reached")
)

Functions

func NewIAMSASLClient

func NewIAMSASLClient(mskhostname, region, useragent string) sarama.SCRAMClient

Types

type IAMSASLClient

type IAMSASLClient struct {
	MSKHostname string
	Region      string
	UserAgent   string
	// contains filtered or unexported fields
}

func (*IAMSASLClient) Begin

func (sc *IAMSASLClient) Begin(username, password, _ string) error

func (*IAMSASLClient) Done

func (sc *IAMSASLClient) Done() bool

func (*IAMSASLClient) Step

func (sc *IAMSASLClient) Step(challenge string) (string, error)