kafka

Documentation

Index

• Constants
• Variables
• func CreateSaslMechanism(saslConfig *clowder.KafkaSASLConfig) (sasl.Mechanism, error)
• func InitializeConsumers()

Constants

const (
	TenMb = 10e7
)

Variables

var Consumer = kafkaConsumer{}

var Dialer *kafka.Dialer

var SaslMechanism sasl.Mechanism

var TlsConfig *tls.Config

Functions

func CreateSaslMechanism

func CreateSaslMechanism(saslConfig *clowder.KafkaSASLConfig) (sasl.Mechanism, error)

func InitializeConsumers

func InitializeConsumers()