发送到当前关闭的 NodeRed 输出节点的数据会发生什么情况？

Question

我目前正在 Node-RED 上实现一个流程，其中 MQTT 订阅者节点将数据发送到 kafka 生产者节点，即 Node-RED 上的输出节点。

如果 Kafka 生产者节点在远程 Kafka 宕机的情况下无法发送数据，那么从 MQTT 订阅者节点推送到 Kafka 生产者节点的数据会发生什么情况。

我不能丢失一个数据集。

Answer 1

这将取决于 Kafka 生产者节点的编写方式，但快速查看 src 它似乎只是记录错误并在传递消息时丢弃消息到卡夫卡

Node-RED 中没有 retry/queuing 内置，它必须添加到给定的输出节点。问题在于确定应该保留什么以及应该将其存储在磁盘上还是内存中...

Answer 2

通过放置一个 "Catch" 节点解决了这个问题，该节点捕获 kafka 生产者节点抛出的错误（如果远程集群不可用，它也会抛出数据和错误）。然后可以提取数据并尝试将其再次发送到新集群。