Hi everyone, i’m a newbie to Flowable and i’m having some problems starting a very simple process that is triggered by a kafka event.
The process it reads from a topic, executes a service task (which simply logs a message) and then ends. The process is inside a SpringBoot application running on Tomcat, i’m using 6.5.0 Flowable version.
This is my process definition:
This is my event definition:
{
“key”: “start”,
“name”: “ProcessStart”,
“inboundChannelKeys”: [“kafkaChannel”],
“correlationParameters”: [
],
“payload”: [
{
“name”: “messaggio”,
“type”: “string”
}
]
}
This is my channel definition:
{
“type”: “kafka”,
“channelType”: “inbound”,
“deserializerType”: “json”,
“channelEventKeyDetection”: {
“fixedValue”: “start”
},
“name”: “KafkaStartChannel”,
“key”: “kafkaChannel”,
“topics”: [
“TRA-SA-0035.flowable”
]
}
My dependencies in the pom.xml:
<dependency>
<groupId>org.flowable</groupId>
<artifactId>flowable-spring-boot-starter</artifactId>
<version>${flowable.version}</version>
</dependency>
<dependency>
<groupId>org.flowable</groupId>
<artifactId>flowable-event-registry-model</artifactId>
<version>6.5.0</version>
</dependency>
I’ve followed the tutorials on the web but I can’t understand where i’m going wrong. The application starts but it doesn’t log, which means that it’s not listening on the Kafka topic.
Thanks,
Narcisa