akka/alpakka-kafka

hello everyone, I'm pretty new to akka framework, I'm trying to consume the data parallely from two different kafka topics as two different streams and i'm using akka.kafka.default-dispatcher. just wanted to know the execution, if i create two different consumers in one application like below.

can you please clarify me on this

1. will this two consumers run in exact parallely with out depending on the another (like multi processing) or will it run in asynchronous fashion ?
2. how will dispatcher configuration(akka.kafka.default-dispatcher) like threadpool and threads helps to achieve this.

any recomendations also acceptable.

object EventConsumer extends App {
  // actor syste and meterializer for streams
  implicit val system = ActorSystem.create("octopus")
  implicit val materializer = ActorMaterializer()

  // consumer setting
  val consumerSettings = ConsumerSettings(system, new StringDeserializer, new StringDeserializer)
    .withBootstrapServers("192.168.1.8:29092")
    .withGroupId("execer-group")

  // event  consumer
  val event_consumer = Consumer
    .committableSource(consumerSettings, Subscriptions.topics("event"))
    .map(msg => {
      // got the message, do what evey you need
      println(s"Got message - event -  ${msg.record.value()}")
    })
    .runWith(Sink.ignore)

  // event  retry consumer
  val event_retry_consumer = Consumer
    .committableSource(consumerSettings, Subscriptions.topics("event_retry"))
    .map(msg => {
      // got the message, do what evey you need
      println(s"Got message - event_retry - ${msg.record.value()}")
    })
    .runWith(Sink.ignore)

  // handle shutdown
  implicit val ec: ExecutionContextExecutor = system.dispatcher
  event_consumer onComplete {
    case Success(_) =>
      println("Successfully terminated consumer")
      system.terminate()
    case Failure(err) =>
      println(err.getMessage)
      system.terminate()
  }

  event_retry_consumer onComplete {
    case Success(_) =>
      println("Successfully terminated consumer")
      system.terminate()
    case Failure(err) =>
      println(err.getMessage)
      system.terminate()
  }
}

Thank you so much.