kafkautils

Documentation

Overview

Package kafkautils provides Kafka utility functions that are shared between ia2 and the HTTP-to-Kafka bridge that ia2 relies on if it's running inside an enclave.

Index

• Constants
• func NewKafkaWriter(certFile, keyFile string) (*kafka.Writer, error)

Constants

const (
	// DefaultKafkaKey holds the default path to the Kafka certificate key.
	DefaultKafkaKey = "/etc/kafka/secrets/key"
	// DefaultKafkaCert holds the default path to the Kafka certificate.
	DefaultKafkaCert = "/etc/kafka/secrets/certificate"
)

Functions

func NewKafkaWriter

func NewKafkaWriter(certFile, keyFile string) (*kafka.Writer, error)

NewKafkaWriter creates a new Kafka writer based on the environment variable envKafkaBroker and the given certificate files.