# \#kafka

**URL:** https://discourse.nodered.org/tag/kafka/155.md

[Latest](https://discourse.nodered.org/latest.md) · [Categories](https://discourse.nodered.org/categories.md) · [Tags](https://discourse.nodered.org/tags.md)

---

## [Using environment variables in kafka consumer topic](https://discourse.nodered.org/t/using-environment-variables-in-kafka-consumer-topic/99321)

<div class="topic-metadata">

**Author:** [@JeroenVH](https://discourse.nodered.org/u/JeroenVH)\
**Replies:** 1\
**Last updated:** [13 October 2025 13:40 UTC](https://discourse.nodered.org/t/using-environment-variables-in-kafka-consumer-topic/99321 "2025-10-13T13:40:57Z")

</div>

The project that I am working on uses the hylink/node-red-kafka-client nodes. I have different flows with identical nodes and configured an environment variable at the flow level to make things inside the flow unique. I…

---

## [Kafka Error "argument must be of type string or instance of Buffer ot ArrayBuffer"](https://discourse.nodered.org/t/kafka-error-argument-must-be-of-type-string-or-instance-of-buffer-ot-arraybuffer/99145)

<div class="topic-metadata">

**Author:** [@mrStark](https://discourse.nodered.org/u/mrStark)\
**Replies:** 12\
**Last updated:** [24 September 2025 08:38 UTC](https://discourse.nodered.org/t/kafka-error-argument-must-be-of-type-string-or-instance-of-buffer-ot-arraybuffer/99145 "2025-09-24T08:38:09Z")

</div>

I'm getting below error when i'm passing some payload to the kafkajs node. I'm using a json node before sending the data to the kafkajs node but still getting the error. Can anyone help here? { "level":"ERROR", "tim…

---

## [Creating an async node that uses pub/sub](https://discourse.nodered.org/t/creating-an-async-node-that-uses-pub-sub/90787)

<div class="topic-metadata">

**Author:** [@seb](https://discourse.nodered.org/u/seb)\
**Replies:** 4\
**Last updated:** [10 September 2024 11:25 UTC](https://discourse.nodered.org/t/creating-an-async-node-that-uses-pub-sub/90787 "2024-09-10T11:25:42Z")

</div>

Hello all, I'd like to create (or ideally use an existing one) a Node-RED node that: Receives an input. Publishes a message to either Kafka or MQTT. Listens to a topic until it receives a response to the original mess…

---

## [What kafka contrib are you using?](https://discourse.nodered.org/t/what-kafka-contrib-are-you-using/90774)

<div class="topic-metadata">

**Author:** [@seb](https://discourse.nodered.org/u/seb)\
**Replies:** 3\
**Last updated:** [8 September 2024 13:37 UTC](https://discourse.nodered.org/t/what-kafka-contrib-are-you-using/90774 "2024-09-08T13:37:48Z")

</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