-
Notifications
You must be signed in to change notification settings - Fork 610
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
panic: kafka: client has run out of available brokers to talk to (Is your cluster reachable?) #98
Comments
This is due to kafka-exporter not supporting SCRAM as a sasl mechanism. At the moment it only supports PLAN as a SASL mechanism. This is due to go library that kafka-exporter uses (samara) didn't support it. However the good news it that samara now supports it IBM/sarama#1295. |
Hi squ1d123, |
I have just opened #101 to support this, feel free to use my branch in the meantime if you want to try it out |
KAFKA_ADVERTISED_LISTENERS: 'PLAINTEXT://:9092' Add this under kakfa docker |
I had the same problem |
im facing the same issue.
Is there any further development in this topic? |
I'm facing the same issue with a Kafka instance running on Confluent.
I usually use SASL PLAIN mechanism to access my Kafka instance for other purposes. I get
UPDATE It works with this configuration:
|
not able to run kafka_exporter with below details :
kafka sasl details in server.properties file:
listener.security.protocol.map=SASL_PLAINTEXT:SASL_PLAINTEXT
sasl.enabled.mechanisms=SCRAM-SHA-256
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=SCRAM-SHA-256
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
Comamnd:
nohup ./kafka_exporter --kafka.version="2.2.0" --no-sasl.handshake --sasl.enabled --sasl.username="xyz" --sasl.password="abc" --kafka.server=10.0.0.1:9091 --kafka.server=10.0.0.2:9092 --kafka.server=10.0.0.3:9093 --log.level="debug" --log.enable-sarama --log.format="logger:syslog?appname=bob&local=7" &
Error:
panic: kafka: client has run out of available brokers to talk to (Is your cluster reachable?)
goroutine 1 [running]:
main.NewExporter(0xc4201d2140, 0x3, 0x4, 0x1, 0x7ffe159a844c, 0x5, 0x7ffe159a8462, 0xe, 0x0, 0x8f22f8, ...)
/go/src/github.com/danielqsj/kafka_exporter/kafka_exporter.go:211 +0x847
main.main()
/go/src/github.com/danielqsj/kafka_exporter/kafka_exporter.go:481 +0x215b
The text was updated successfully, but these errors were encountered: