我遇到过用于 JBPM (7.18.0) 的 Kafka WorkItem,用于将消息发布到 kafka 主题。
但是当主题中有消息时,如何触发特定的工作流程。
或者如果主题中有消息,流程如何恢复
据我所知,其中唯一的代码是生产者,而不是消费者
我想这个问题的解决方法是编写你自己的消费者,并将其放在通用的Java操作中,但这需要处于无限轮询循环中,最好是在进程本身的单独线程中,所以我不确定它将如何触发后续操作
找到这篇文章,描述如何通过标准“消息”任务使用kafka:https://blog.kie.org/2020/12/jbpm-messages-and-kafka.html
(不过我还没试过。)