Количество параллельных задач в Spark Streaming и Kafka Integration

Я очень новичок в Spark Streaming. У меня есть некоторые основные сомнения. Может кто-нибудь, пожалуйста, помогите мне прояснить это:

1. Размер моего сообщения стандартный. 1Кб каждое сообщение.

2. Количество разделов темы составляет 30, и используется подход dstream для получения сообщения от kafka.

3. Количество ядер, отдаваемых искре, как:

   ( spark.max.cores=6| spark.executor.cores=2)

4. Насколько я понимаю, количество разделов Kafka = количество разделов RDD:

    In this case dstream approach:
   
    dstream.forEachRdd(rdd->{
    rdd.forEachPartition{
    }
   
     **Question**:This loop forEachPartiton will execute 30 times??As there are 30 Kafka partitions
   

   }

5. Также так как я дал 6 ядер, сколько партиций будет израсходовано параллельно из kafka

   Вопросы: Это 6 разделов одновременно? или
   30/6 = 5 разделов одновременно? Может кто-нибудь рассказать немного о том, как это работает в подходе dstream.