我正在尝试在集群上运行 flink 应用程序。应用程序部署成功，我可以看到 jobmanger 和 taskmanager 正在运行并且资源注册成功。
应用程序需要虚拟事件，它工作正常，sql 查询也返回结果（通过任务管理器）。
问题：应用程序从消息集线器接收事件，但这些消息仅与作业管理器一起使用，并到达任务管理器以在集群（独立）中执行。但它适用于 intelliJ。
我知道它是否会有 kafka 然后 addSource(new FlinkKafkaConsumer()) 工作，但对我来说，我必须注册回调，然后消息出现 onEvent。
是否有任何机制可以帮助从集群中的作业管理器向任务管理器发送事件？