kafka

package
v4.22.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 23, 2023 License: MIT Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var AWSSASLFromConfigFn = notImportedAWSFn

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

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

SASL specific error types.

SHA256 generates the SHA256 hash.

SHA512 generates the SHA512 hash.

Functions

func ApplySaramaSASLFromParsed

func ApplySaramaSASLFromParsed(pConf *service.ParsedConfig, mgr *service.Resources, conf *sarama.Config) error

ApplySaramaSASLFromParsed applies a parsed config containing a SASL field to a sarama.Config.

func NewKafkaWriterFromParsed

func NewKafkaWriterFromParsed(conf *service.ParsedConfig, mgr *service.Resources) (service.BatchOutput, error)

NewKafkaWriteFromParsed returns a kafka output from a parsed config.

func OSKConfigSpec

func OSKConfigSpec() *service.ConfigSpec

OSKConfigSpec creates a new config spec for a kafka output.

func SaramaSASLField

func SaramaSASLField() *service.ConfigField

SaramaSASLField returns a field spec definition for SASL within the sarama components.

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.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL