Демонстрационный проект перехвата сообщения из брокера сообщений Kafka и передачи его в Camunda Engine.
На данный момент реализован только один вид сообщений - стартовые.
runtimeService.correlateMessage(...)
...
.correlateStartMessage();
Но можно легко создавать практически все стартовые и промежуточные события стандарта BPMN 2.0.