У меня есть приложение для потоковой передачи, которое потребляет данные из темы 1 и анализирует их...