dfiai commented on issue #3337:
URL: 
https://github.com/apache/incubator-kie-kogito-runtimes/issues/3337#issuecomment-1895961755

   > Yes, There are two different problems: one related with the existence of 
two consumers over the same process instance (the one you initially describe 
and I rule out as an issue because I did not realize that signalProcessInstance 
will be invoked twice) and another one related on how smallrye handle two 
incoming channels over the same topic (the second channel, mosf ot the times, 
did not receive any event, causing the process stuck you are seeing when you 
start using two channels over the same topic) . Im working on a fix for the 
first, which will be enough for your case. The second one is more tricky 
because there is some kind of race condition (sometimes it work for me, meaning 
the process completed, sometimes it is stuck, it all depends on which receiver 
consume the event, whichs seems to be random)
   
   For the second scenario, it's expected behavior in Kafka that each partition 
is consumed by only one consumer from the same consumer group. The smallrey 
behavior aligns with my understanding of Kafka


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to