franz-kafka
franz-kafka copied to clipboard
zkConnector - _createBroker issue
https://github.com/dannycoates/franz-kafka/blob/master/zkconnector.js#L70
This line using the splits on ":" of the info string. But while debugging I found out that the info string is {"jmx_port":-1,"timestamp":"1458933233150","host":"ip-172-31-5-57.ec2.internal","version":1,"port":9092} So while passing I think we might have to convert it into a json object and then use host and port.
Am I right?
I just found this too. A bit weird... I suppose it might be to do with the message changing in a version of Kafka?
It's now line 68 https://github.com/dannycoates/franz-kafka/blob/3b36c4211fee7ad2f83c18ed08b0ea8673228274/zkconnector.js#L68