Not sure I'm convinced the effort of switching streaming frameworks is worth it as opposed to switching to a jvm compiled language.