First I want to thank you for providing this excellent, full-featured node.
Apologies if this issue has already been raised and addressed.
When starting Node-red without an accessible Kafka broker to connect to, the "producer" node retries to connect 5 times and then throws an unhandled exception which crashes the whole NR server process. I need to keep the node disabled, and enable it only when Kafka is up.
{"level":"ERROR","timestamp":"2022-02-22T17:18:18.073Z","logger":"kafkajs","message":"[Connection] Connection error: connect ECONNREFUSED 10.235.247.97:9092","broker":"ILRNARADEMO01:9092","clientId":"MyApp","stack":"Error: connect ECONNREFUSED 10.235.247.97:9092\n at TCPConnectWrap.afterConnect [as oncomplete] (node:net:1142:16)"}
{"level":"ERROR","timestamp":"2022-02-22T17:18:18.075Z","logger":"kafkajs","message":"[BrokerPool] Failed to connect to seed broker, trying another broker from the list: Connection error: connect ECONNREFUSED 10.235.247.97:9092","retryCount":5,"retryTime":5784}
22 Feb 19:18:18 - [red] Uncaught Exception:
22 Feb 19:18:18 - [error] KafkaJSNonRetriableError
Caused by: KafkaJSConnectionError: Connection error: connect ECONNREFUSED 10.235.247.97:9092
at Socket.onError (C:\ProgramData\Node-red\node_modules\kafkajs\src\network\connection.js:152:23)
at Socket.emit (node:events:394:28)
at emitErrorNT (node:internal/streams/destroy:157:8)
at emitErrorCloseNT (node:internal/streams/destroy:122:3)
at processTicksAndRejections (node:internal/process/task_queues:83:21)
C:\Windows\system32>
Is there a way around this (or am I doing something wrong)?
First I want to thank you for providing this excellent, full-featured node. Apologies if this issue has already been raised and addressed.
When starting Node-red without an accessible Kafka broker to connect to, the "producer" node retries to connect 5 times and then throws an unhandled exception which crashes the whole NR server process. I need to keep the node disabled, and enable it only when Kafka is up.
{"level":"ERROR","timestamp":"2022-02-22T17:18:18.073Z","logger":"kafkajs","message":"[Connection] Connection error: connect ECONNREFUSED 10.235.247.97:9092","broker":"ILRNARADEMO01:9092","clientId":"MyApp","stack":"Error: connect ECONNREFUSED 10.235.247.97:9092\n at TCPConnectWrap.afterConnect [as oncomplete] (node:net:1142:16)"} {"level":"ERROR","timestamp":"2022-02-22T17:18:18.075Z","logger":"kafkajs","message":"[BrokerPool] Failed to connect to seed broker, trying another broker from the list: Connection error: connect ECONNREFUSED 10.235.247.97:9092","retryCount":5,"retryTime":5784} 22 Feb 19:18:18 - [red] Uncaught Exception: 22 Feb 19:18:18 - [error] KafkaJSNonRetriableError Caused by: KafkaJSConnectionError: Connection error: connect ECONNREFUSED 10.235.247.97:9092 at Socket.onError (C:\ProgramData\Node-red\node_modules\kafkajs\src\network\connection.js:152:23) at Socket.emit (node:events:394:28) at emitErrorNT (node:internal/streams/destroy:157:8) at emitErrorCloseNT (node:internal/streams/destroy:122:3) at processTicksAndRejections (node:internal/process/task_queues:83:21) C:\Windows\system32>
Is there a way around this (or am I doing something wrong)?
Thanks, Omri