Concorrência de transmissão Kafka?

Eu tenho algum código básico do Kafka Streaming que lê registros de um tópico, faz algum processamento e gera registros para outro tópico.

Como o streaming Kafka lida com a simultaneidade? Tudo é executado em um único thread? Não vejo isso mencionado na documentação.

Se for um encadeamento único, eu gostaria de opções para processamento multiencadeado para lidar com grandes volumes de dados.

Se for multiencadeado, preciso entender como isso funciona e como manipular recursos, como as conexões com o banco de dados SQL devem ser compartilhadas em diferentes encadeamentos de processamento.

A API de streaming interna do Kafka não é recomendada para cenários de alto volume em relação a outras opções (Spark, Akka, Samza, Storm, etc)?

questionAnswers(2)

yourAnswerToTheQuestion