kafka

Documentation

Index

• func GenerateCodecs(codecs map[string]string) (map[string]*goavro.Codec, error)
• func InitKafkaWriter(ctx context.Context, topic string) (*kafka.Writer, *kafka.Dialer, error)
• func InstrumentKafka(ctx context.Context)
• func TLSDialer() (*kafka.Dialer, *x509.Certificate, error)

Functions

func GenerateCodecs

func GenerateCodecs(codecs map[string]string) (map[string]*goavro.Codec, error)

GenerateCodecs - create a map of codec name to the avro codec

func InitKafkaWriter

func InitKafkaWriter(ctx context.Context, topic string) (*kafka.Writer, *kafka.Dialer, error)

InitKafkaWriter - create a kafka writer given a topic

func InstrumentKafka

func InstrumentKafka(ctx context.Context)

InstrumentKafka - setup instrumentation and metrics around our kafka connection

func TLSDialer

func TLSDialer() (*kafka.Dialer, *x509.Certificate, error)

TLSDialer creates a Kafka dialer over TLS. The function requires KAFKA_SSL_CERTIFICATE_LOCATION and KAFKA_SSL_KEY_LOCATION environment variables to be set.