kafka

Documentation

Index

• type KafkaLogger
  • func NewKafkaLogger(l logger.Logger, opts ...Opt) *KafkaLogger
  • func (l *KafkaLogger) Level() kgo.LogLevel
  • func (l *KafkaLogger) Log(level kgo.LogLevel, msg string, keyvals ...interface{})
• type Opt
  • func WithLevel(level logger.Level) Opt
  • func WithLevelFn(fn func() kgo.LogLevel) Opt

Types

type KafkaLogger

type KafkaLogger struct {
	// contains filtered or unexported fields
}

func NewKafkaLogger

func NewKafkaLogger(l logger.Logger, opts ...Opt) *KafkaLogger

func (*KafkaLogger) Level

func (l *KafkaLogger) Level() kgo.LogLevel

Level is for the kgo.Logger interface.

func (*KafkaLogger) Log

func (l *KafkaLogger) Log(level kgo.LogLevel, msg string, keyvals ...interface{})

type Opt

type Opt interface {
	// contains filtered or unexported methods
}

Opt applies options to the kafka logger.

func WithLevel

func WithLevel(level logger.Level) Opt

WithLevel sets a static level for the kgo.Logger Level function.

func WithLevelFn

func WithLevelFn(fn func() kgo.LogLevel) Opt

WithLevelFn sets a function that can dynamically change the log level.