Tengo un código básico de Kafka Streaming que lee registros de un tema, procesa y envía registros a otro tema.

¿Cómo maneja Kafka streaming la concurrencia? ¿Todo se ejecuta en un solo hilo? No veo esto mencionado en la documentación.

Si es de un solo subproceso, me gustaría tener opciones para el procesamiento de subprocesos múltiples para manejar grandes volúmenes de datos.

Si es multiproceso, necesito entender cómo funciona esto y cómo manejar los recursos, como las conexiones de bases de datos SQL deben compartirse en diferentes subprocesos de procesamiento.

¿No se recomienda la API de transmisión integrada de Kafka para escenarios de alto volumen en relación con otras opciones (Spark, Akka, Samza, Storm, etc.)?