# What kafka contrib are you using?

**URL:** https://discourse.nodered.org/t/what-kafka-contrib-are-you-using/90774
**Category:** General
**Tags:** kafka
**Created:** [7 September 2024 17:08 UTC](https://discourse.nodered.org/t/what-kafka-contrib-are-you-using/90774 "2024-09-07T17:08:23Z")
**Posts on this page:** 5
**Page:** 1

<div class="post-metadata">

### Author: ![seb](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/seb/32/94157_2.png) [@seb](https://discourse.nodered.org/u/seb)
#### Post date: [7 September 2024 17:08 UTC](https://discourse.nodered.org/t/what-kafka-contrib-are-you-using/90774/1 "2024-09-07T17:08:23Z")

</div>

Hi, There are plenty of kafka nodes but they all seems not being updated. Is kafka a out of topic for node-red ? if not, which library are you using ?

thanks

---

<div class="post-metadata">

### Author: ![marcus-j-davies](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/marcus-j-davies/32/103435_2.png) [@marcus-j-davies](https://discourse.nodered.org/u/marcus-j-davies)
#### Post date: [7 September 2024 17:13 UTC](https://discourse.nodered.org/t/what-kafka-contrib-are-you-using/90774/2 "2024-09-07T17:13:03Z")

</div>

Hi @seb

I have moved this out of **Share Your Nodes** - As you don't seem to be sharing a Node you have developed.

As for **Is kafka a out of topic for node-red**

Not at all....  
Its whether or not the community has interest.

I have tagged this as **kafka** to help focus on those that might have input

---

<div class="post-metadata">

### Author: ![bakman2](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/bakman2/32/6207_2.png) [@bakman2](https://discourse.nodered.org/u/bakman2)
#### Post date: [7 September 2024 21:42 UTC](https://discourse.nodered.org/t/what-kafka-contrib-are-you-using/90774/3 "2024-09-07T21:42:01Z")

</div>

[node-red-kafkajs](https://flows.nodered.org/node/@asinino/node-red-kafkajs) was updated last month.

Last time i used a kafka client, it was [node-red-contrib-kafkajs](https://flows.nodered.org/node/node-red-contrib-kafkajs), not too long ago also works.

---

<div class="post-metadata">

### Author: ![omrid](https://avatars.discourse-cdn.com/v4/letter/o/77aa72/32.png) [@omrid](https://discourse.nodered.org/u/omrid)
#### Post date: [8 September 2024 13:37 UTC](https://discourse.nodered.org/t/what-kafka-contrib-are-you-using/90774/4 "2024-09-08T13:37:48Z")

</div>

I have been using `node-red-contrib-kafkajs` for quite a while. Its latest release was 3 years ago. It works, but has a few issues:

1. If the producer node fails to connect to a broker after the retries expire, it throws an unhandled exception which crashes **the entire Node-RED server process**.
2. The node does not recover from temporary loss of the broker connection
3. When catching an error, the node returns only the thrown error without the msg, so you cannot associate it the original sent message
4. When trying to send a message when the broker is not ready, it ignores and does not return an error

We upgraded to `@digproc/node-red-contrib-kafkajs` (latest version is v0.0.9), which updated the dependencies to a more current kafkajs, but did not address the above issues.

So we had to patch the node locally for the above issues. Now we started testing `@asinino/node-red-kafkajs` which was released a month ago, and so far looks good, and solves the above issues.

---

<div class="post-metadata">

### Author: ![system](https://us1.discourse-cdn.com/flex026/uploads/nodered/original/1X/d073cd938eafa2e558d7c2cd59003b3ef4963033.png) [@system](https://discourse.nodered.org/u/system)
#### Post date: [7 December 2024 13:38 UTC](https://discourse.nodered.org/t/what-kafka-contrib-are-you-using/90774/5 "2024-12-07T13:38:04Z")

</div>

This topic was automatically closed 90 days after the last reply. New replies are no longer allowed.
