I’m currently using n8n version 1.98.1. My main workflow is checking Kafka topic message consumption. I’m using a Kafka Trigger node and Redis to receive messages. I’ve noticed that after a certain period, the workflow stops receiving messages. I’ve tried pushing around 1000 messages to the Kafka topic and then activating the workflow. It only receives about 900 messages and then stops receiving any more. Other times, it only receives a few messages before stopping entirely. Please help me investigate this.
I’ve already tried creating a separate project using kafkajs and it successfully receives all messages. Do you have any ideas about this issue?