Основы Kafka Streams объяснение

У меня есть несколько вопросов относительно потоков Kafka и того, как они работают, я знаком с общей парадигмой потребителей и производителей Kafka, однако я впервые пытаюсь использовать потоки Kafka.

Вопросы:

1. В общей модели потребителя Kafka мы подписываемся на тему и начинаем потреблять с раздела, для простоты предположим, что у нас есть 1 раздел и 1 потребитель, теперь, если мы хотим увеличить нашу обработку, мы увеличиваем количество разделов и дополнительно добавляем больше потребителей, как это работает в Kafka Streams, если мы увеличиваем разделы, как нам масштабировать приложение, нужно ли нам добавлять больше машин или нам нужно делать что-то еще?
2. Когда я потребляю данные через потребителей Kafka, я могу в конечном итоге что-то сделать с сообщениями, например, я могу запросить API, загрузить файл и записать в NFS и перенаправить сообщение или записать значение входящего сообщения в базу данных, а затем перенаправить уведомление в другую тему Kafka, как решается тот же вариант использования, когда мы не следуем парадигме KAFKA -> KAFKA, а вместо этого используем KAFKA -> PROCESS(STORE IN DB) -> KAFKA, могут ли потоки Kafka решить этот вариант использования?
3. Наконец, как обрабатываются исключения и как управляются смещения. В постоянно работающих производственных системах, куда поступает бесконечный поток сообщений, в случае каких-либо исключений, например, из-за сбоя в сети, мы отключаем потребителей и выполняем чистую установку. Как добиться того же с приложением обработки Kafka Stream?