Trigger Kafka works randomly

I’m trying to connect a Kafka trigger to a kafka server.
It works fine locally, but in another environment with SASL, it’s random.

I’m getting datas from a topic but when I’m trying to do it, the process keeps running. If I try several times, sometimes it works.

If I’m trying to get data from another topic, it always works.

There is nothing in logs. I have the lastest version.
In the consumer group, the working topic is present but never the random one.
I’ve tried to delete/recreate.

I don’t understand why and I don’t know what to try.
If someone got an idea…

It looks like your topic is missing some important information. Could you provide the following if applicable.

  • n8n version:
  • Database (default: SQLite):
  • n8n EXECUTIONS_PROCESS setting (default: own, main):
  • Running n8n via (Docker, npm, n8n cloud, desktop app):
  • Operating system:

Hi @dam358 thanks for reaching out and being a part of the community! This may be a bit dated, but it does seem like we’ve had community members encounter that issue previously: Not able to connect to Kafka - #3 by aanogueira

It resulted in this addition to the Kafka credential: ⚡️ Add SASL mechanism option in Kafka by ahsanv · Pull Request #1525 · n8n-io/n8n · GitHub