Skip to content
This repository has been archived by the owner on Jan 26, 2018. It is now read-only.

zkConnector - _createBroker issue #14

Open
shrimalmadhur opened this issue Mar 26, 2016 · 1 comment
Open

zkConnector - _createBroker issue #14

shrimalmadhur opened this issue Mar 26, 2016 · 1 comment

Comments

@shrimalmadhur
Copy link

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?

@ISNIT0
Copy link

ISNIT0 commented Nov 17, 2017

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

var hostPort = info.split(':')

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants