apache-kafka - JBPM：当Kafka Topic中有消息时触发业务流程

Question

我遇到了 Kafka WorkItem for JBPM (7.18.0) 用于将消息发布到 kafka 主题。

但是当主题中有消息时，我如何触发特定的工作流。

或者如果主题中有消息，该过程如何恢复

标签： apache-kafkajbpm

Answer 1

据我所知，唯一的代码是生产者，而不是消费者

https://github.com/kiegroup/jbpm-work-items/tree/master/kafka-workitem/src/main/java/org/jbpm/process/workitem/kafka

我想解决方法是编写您自己的消费者，并将其粘贴在通用 Java 操作中，但这需要处于无限轮询循环中，最好是在进程本身的单独线程中，所以我不确定它将如何触发以后的操作