val kafkaSink = RestartSink
      .withBackoff(
        minBackoff = 5.seconds,
        maxBackoff = 60.seconds,
        randomFactor = .2
      ) { () =>
        Producer.plainSink(kafkaProducerSetting)
      }
      .mapMaterializedValue[Future[Done]](_ => Future.successful(Done))