# Can't catch event from Kafka

**URL:** <https://forum.flowable.org/t/cant-catch-event-from-kafka/6990>\
**Category:** Flowable Engine\
**Created:** [October 28, 2020, 6:56pm UTC](https://forum.flowable.org/t/cant-catch-event-from-kafka/6990 "2020-10-28T18:56:23Z")\
**Posts on this page:** 5\
**Page:** 1

<div class="post-metadata">

**Author:** ![nrus](https://avatars.discourse-cdn.com/v4/letter/n/a9adbd/32.png) [@nrus](https://forum.flowable.org/u/nrus)\
**Post date:** [October 28, 2020, 6:56pm UTC](https://forum.flowable.org/t/cant-catch-event-from-kafka/6990/1 "2020-10-28T18:56:23Z")

</div>

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](https://canada1.discourse-cdn.com/flex035/uploads/flowable/original/2X/e/e733b960eba220e28859433ea951c8a80640ab9f.png)

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

---

<div class="post-metadata">

**Author:** ![joram](https://yyz1.discourse-cdn.com/flex035/user_avatar/forum.flowable.org/joram/32/26_2.png) [@joram](https://forum.flowable.org/u/joram)\
**Post date:** [October 28, 2020, 8:58pm UTC](https://forum.flowable.org/t/cant-catch-event-from-kafka/6990/2 "2020-10-28T20:58:29Z")

</div>

> [@nrus](#):
>
> PS: I’m using Flowable 6.5.0 + Springboot 2.2.4

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

---

<div class="post-metadata">

**Author:** ![nrus](https://avatars.discourse-cdn.com/v4/letter/n/a9adbd/32.png) [@nrus](https://forum.flowable.org/u/nrus)\
**Post date:** [October 29, 2020, 11:04am UTC](https://forum.flowable.org/t/cant-catch-event-from-kafka/6990/3 "2020-10-29T11:04:26Z")

</div>

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](https://canada1.discourse-cdn.com/flex035/uploads/flowable/original/2X/f/f03062829909efc22b7abcc44132324f9fcad7bf.png)

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

---

<div class="post-metadata">

**Author:** ![nrus](https://avatars.discourse-cdn.com/v4/letter/n/a9adbd/32.png) [@nrus](https://forum.flowable.org/u/nrus)\
**Post date:** [November 3, 2020, 6:31am UTC](https://forum.flowable.org/t/cant-catch-event-from-kafka/6990/4 "2020-11-03T06:31:15Z")

</div>

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

---

<div class="post-metadata">

**Author:** ![joram](https://yyz1.discourse-cdn.com/flex035/user_avatar/forum.flowable.org/joram/32/26_2.png) [@joram](https://forum.flowable.org/u/joram)\
**Post date:** [November 9, 2020, 8:48am UTC](https://forum.flowable.org/t/cant-catch-event-from-kafka/6990/5 "2020-11-09T08:48:33Z")

</div>

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?

> [@nrus](#):
>
> Would you please help me? I have a deadline soon and I need to solve this problem.

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