Function newLogger

pkg/ingest/logger.go:15–19

(l log.Logger)

}

func newLogger(l log.Logger) *logger {
	return &logger{
		logger: log.With(l, "component", "kafka_client"),
	}
}

func (l *logger) Level() kgo.LogLevel {
	// The Kafka client calls Level() to check whether debug level is enabled or not.