code: func init() {
  	loggingProvider := flogging.MustGetLogger("orderer.consensus.kafka.sarama")
  	saramaEventLogger := &saramaLoggerImpl{
  		logger: loggingProvider.WithOptions(zap.AddCallerSkip(3)),
  		eventListenerSupport: &eventListenerSupport{
  			listeners: make(map[string][]chan string),
  		},
  	}
  	sarama.Logger = saramaEventLogger
  	saramaLogger = saramaEventLogger
  }
docs: // init initializes the samara logger