util

Documentation

Index

• Constants
• func GetEnv(key, defaultValue string) string
• type SaramaZapLogger
  • func (sz SaramaZapLogger) Print(v ...interface{})
  • func (sz SaramaZapLogger) Printf(format string, v ...interface{})
  • func (sz SaramaZapLogger) Println(v ...interface{})

Constants

const (
	// KafkaBrokersEnv is the kafka brokers environment variable name
	KafkaBrokersEnv = "KAFKA_BROKERS"
	// KafkaTopicEnv is the kafka topic environment variable name
	KafkaTopicEnv = "KAFKA_TOPIC"
)

Functions

func GetEnv

func GetEnv(key, defaultValue string) string

GetEnv will lookup a environment variable or return the default

Types

type SaramaZapLogger

type SaramaZapLogger struct{}

SaramaZapLogger is a zap logger for sarama

func (SaramaZapLogger) Print

func (sz SaramaZapLogger) Print(v ...interface{})

Print will Print a log message to zap info

func (SaramaZapLogger) Printf

func (sz SaramaZapLogger) Printf(format string, v ...interface{})

Printf will Printf a log message to zap info

func (SaramaZapLogger) Println

func (sz SaramaZapLogger) Println(v ...interface{})

Println will Println a log message to zap info