Как мы можем обрабатывать данные из источников JMS (например, Solace) в потоковой передаче с искровой структурой?Может видеть реализации с Dstreams, но ничего, используя новую структурированную потоковую передачу.Какие-нибудь указатели или подсказки искрово структурированного потокового вещания и JMS были бы хороши?