Can't catch event from Kafka

Flowable Engine
1

Hello everyone,
I’m trying to use the Event Registry to catch at some point of my process a message from Kafka, so i modelled this scenario with a Intermediate Event Registry Catching Event .
In my process definition i have:

image
image893×93 5.82 KB

and my event definition:
{
“key”: “deployingEvent”,
“name”: “Intermediate deploying modules event”,
“inboundChannelKeys”: [“kafkaInternalChannel”],
“correlationParameters”: [
],
“payload”: [
{
“name”: “idModulo”,
“type”: “string”
},
{
“name”: “versioneModulo”,
“type”: “string”
},
{
“name”: “idCliente”,
“type”: “string”
}

]
}

channel definition:
{
“type”: “kafka”,
“channelType”: “inbound”,
“deserializerType”: “json”,
“channelEventKeyDetection”: {
“fixedValue”: “deployingEvent”
},
“name”: “Channel for intermediate Deploying Event”,
“key”: “kafkaInternalChannel”,
“topics”: [
“TRA-SA-0035.deploy-moduli”
]
}

The error i get is:
[Validation set: ‘flowable-executable-process’ | Problem: ‘flowable-intermediate-catch-event-no-eventdefinition’] : No event definition for intermediate catch event -

Is my configuration right?

PS: I’m using Flowable 6.5.0 + Springboot 2.2.4

Thanks,
Narcisa

2

What you’re trying to do is only supported on Flowable 6.6.0, where this intermediate catch was added.

3

hi @joram, thank you for your fast reply. Upgrading Flowables’s version worked, now my application starts.

I’m facing now another issue, it seems like my app can’t recognize the event even though i defined the correlation parameters (which were missing before). The event definition now is:
image

As you can see i’m interested in a Kafka event with a value in the field idCliente that matches with my process variable idCliente.

This is an example of Kafka message:
{“idModulo”:3,“versioneModulo”:“2.0”,“idCliente”:“id_org_1”}

Is there any misconfiguration?

thank you,
Narcisa

4

Hi @joram seems that the event receiver is now working, but it reads all the messages on the topic regardless the correlationParameter. As I said in the previous post, I want to read only the messages with a “clientId” that has the same value as my “clientId” variable in the process.

Would you please help me? I have a deadline soon and I need to solve this problem.

thank you

5

Correlation parameters are set at runtime. So when the instance of the event is created (called an event subscription internally), the correllation parameters for that instance are calculated and persisted. Can you share how you’re model looks like?

We’re trying to help everybody here. Everyone here (us included ;-)) have deadlines …