hjespers / node-red-contrib-confluent Goto Github PK

I am getting below error
[confluent] Error in our kafka input stream
{ Error
at Object. (/Users/abhishek.y.hingu/.node-red/node_modules/kafka-rest/lib/client.js:201:22)
at Module._compile (module.js:570:32)
at Object.Module._extensions..js (module.js:579:10)
at Module.load (module.js:487:32)
at tryModuleLoad (module.js:446:12)
at Function.Module._load (module.js:438:3)
at Module.require (module.js:497:17)
at require (internal/module.js:20:19)
at Object. (/Users/abhishek.y.hingu/.node-red/node_modules/kafka-rest/index.js:18:14)
at Module._compile (module.js:570:32)
at Object.Module._extensions..js (module.js:579:10)
at Module.load (module.js:487:32)
at tryModuleLoad (module.js:446:12)
at Function.Module._load (module.js:438:3)
at Module.require (module.js:497:17)
at require (internal/module.js:20:19)
name: 'APIError',
status: 500,
message: 'Internal Server Error',
data: { error_code: 500, message: 'Internal Server Error' } }

my node-red workflow
[{"id":"a25f37fe.658048","type":"debug","z":"7d647e6b.eab55","name":"","active":true,"console":"true","complete":"true","x":688,"y":408,"wires":[]},{"id":"910816c7.72b648","type":"confluent out","z":"7d647e6b.eab55","name":"","topic":"testp","key":"","partition":"","proxy":"4295c61d.b1aae8","x":636,"y":331,"wires":[[]]},{"id":"1ac8918b.37d99e","type":"inject","z":"7d647e6b.eab55","name":"","topic":"","payload":"","payloadType":"date","repeat":"1","crontab":"","once":true,"x":472,"y":345,"wires":[["910816c7.72b648"]]},{"id":"42ac37ac.30fea8","type":"confluent in","z":"7d647e6b.eab55","name":"","topic":"testp","cgroup":"node-red-confluent","autocommit":true,"proxy":"4295c61d.b1aae8","x":501,"y":399,"wires":[["a25f37fe.658048"]]},{"id":"4295c61d.b1aae8","type":"rest-proxy","z":"","proxy":"http://localhost:8082","clientid":""}]

Both HTTP and HTTPS are supported by confluentinc/kafka-rest-node so I should add a checkbox for SSL/TLS encryption from the client to the REST Proxy.

I create a inbound node, set my REST URL and always takes down my node-red

enhance the existing metadata node to include broker lists, topic lists. and partition meta-data (all of which are supported by the confluent node.js wrapper in the REST Proxy.

I would like to add support for AVRO but the existing Confluent node.js wrapper on the REST Proxy has a bug that doesn't allow new schemas to be properly registered. I might be able to get this to work for schemas that are registered "out-of-band" though.