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