title: Why Logging is Not Working for Akka Stream
body: <p>I am using Alpakka and have toy example below:</p>
  
  <pre><code>val system = ActorSystem("system")
  implicit val materializer: ActorMaterializer = ActorMaterializer.create(system)
  
  implicit val adapter: LoggingAdapter = Logging(system, "customLogger")
  implicit val ec: ExecutionContextExecutor = system.dispatcher
  
  val log = Logger(this.getClass, "Foo")
  
  val consumerConfig = system.settings.config.getConfig("akka.kafka.consumer")
  val consumerSettings: ConsumerSettings[String, String] =
    ConsumerSettings(consumerConfig, new StringDeserializer, new StringDeserializer)
      .withBootstrapServers("localhost:9092")
      .withGroupId("my-group")
  
  def start() = {
    Consumer.plainSource(consumerSettings, Subscriptions.topics("test"))
      .log("My Consumer: ")
      .withAttributes(
        Attributes.logLevels(
          onElement = Logging.InfoLevel,
          onFinish = Logging.InfoLevel,
          onFailure = Logging.DebugLevel
        )
      )
      .filter(//some predicate)
      .map(// some process)
      .map(out =&gt; ByteString(out))
      .runWith(LogRotatorSink(timeFunc))
      .onComplete {
        case Success(_) =&gt; log.info("DONE")
        case Failure(e) =&gt; log.error("ERROR")
      }
  }
  </code></pre>
  
  <p>This code is working. But I having problem with logging. The first part with attributes is logging fine. When element coming in, it makes log to standard output. But when LogRotatorSink is finishing and future is completing I want to print DONE to standard output. This is not working. File is being produced so process is working but no "DONE" messaging to standard output. </p>
  
  <p>How I get "DONE" to standard output please?</p>
  
  <pre><code>akka {
  
    # Loggers to register at boot time (akka.event.Logging$DefaultLogger logs
    # to STDOUT)
    loggers = ["akka.event.slf4j.Slf4jLogger"]
  
    # Log level used by the configured loggers (see "loggers") as soon
    # as they have been started; before that, see "stdout-loglevel"
    # Options: OFF, ERROR, WARNING, INFO, DEBUG
    loglevel = "INFO"
  
    # Log level for the very basic logger activated during ActorSystem startup.
    # This logger prints the log messages to stdout (System.out).
    # Options: OFF, ERROR, WARNING, INFO, DEBUG
    stdout-loglevel = "INFO"
  
    # Filter of log events that is used by the LoggingAdapter before
    # publishing log events to the eventStream.
    logging-filter = "akka.event.slf4j.Slf4jLoggingFilter"
  
  }
  
  
  &lt;configuration&gt;
  
      &lt;appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"&gt;
          &lt;encoder&gt;
              &lt;pattern&gt;%highlight(%date{HH:mm:ss.SSS} %-5level %-50.50([%logger{50}])) - %msg%n&lt;/pattern&gt;
          &lt;/encoder&gt;
      &lt;/appender&gt;
  
      &lt;logger name="org.apache.kafka" level="INFO"/&gt;
  
      &lt;root level="INFO"&gt;
          &lt;appender-ref ref="STDOUT"/&gt;
      &lt;/root&gt;
  
  &lt;/configuration&gt;
  </code></pre>