Как реализовывали параллельную обработку запросов с помощью Kafka? В чём заключалась реализация?