是否有可能仅通过消息触发oozie工作流程即使用kafka

问题描述

我想绕过 starttime frequency 参数,以便在从kafka代理收到消息后立即启动工作流程。 可以向oozie添加一些插件/类来实现这一点吗?

解决方法

由于Oozie没有事件驱动的协调员,因此您需要创建一个使用者来提交Oozie工作流。

NiFi会更加符合您的工作