Обработка потоковых данных с помощью ksqlDB

Представим следующую задачу: