I’m trying to create a workflow that is triggered when a message is written to a kakfa topic and depending whether an id is present in the message, run the rest of the graph. When using the Kafka event listener, is it possible to also pass the message that triggered the event to the graph as well?
The Kafka Message Listener is basically really only listening for a new message. It is not committing any read action and basically not really reading the message. The reading action itself needs to be done in the job that is executed by the listener. Therefore, when you start reading from the same topic in the consecutive job and the previous messages have been committed, the first message that you get is the message that triggered the listener.
Let me know if that answers your question, please.