goutham created KAFKA-8353:
------------------------------
Summary: org.apache.kafka.common.errors.TimeoutException: Failed
to update metadata after 60000 ms after enabling SASL PLAINTEXT authentication
Key: KAFKA-8353
URL: https://issues.apache.org/jira/browse/KAFKA-8353
Project: Kafka
Issue Type: Bug
Components: documentation, security
Affects Versions: 0.10.2.1
Reporter: goutham
I'm running into time out exception when i try to run producer and consumer
through java or console.
*kafka server.properties*
[advertised.host.name|http://advertised.host.name/]=127.0.0.1
listeners=SASL_PLAINTEXT://[127.0.0.1:9090|http://127.0.0.1:9090/]
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN
advertised.listeners=SASL_PLAINTEXT://[127.0.0.1:9090|http://127.0.0.1:9090/]
*kafka server jass conf*
KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin"
password="admin"
user_admin="admin"
user_test="test";
};
*client producer/consumer properties*
String jaasTemplate = "org.apache.kafka.common.security.plain.PlainLoginModule
required username=\"%s\" password=\"%s\";";
String jaasCfg = String.format(jaasTemplate, "test", "test");
brokers.delete(brokers.length() - 1, brokers.length());
properties.put("bootstrap.servers", brokers.toString());
properties.put("[retry.backoff.ms|http://retry.backoff.ms/]";, "1000");
properties.put("[reconnect.backoff.ms|http://reconnect.backoff.ms/]";, "1000");
properties.put("max.request.size", "5242880");
properties.put("key.serializer",
"org.apache.kafka.common.serialization.ByteArraySerializer");
properties.put("value.serializer",
"org.apache.kafka.common.serialization.ByteArraySerializer");
// properties.put("[metadata.max.age.ms|http://metadata.max.age.ms/]";, 15000);
//Refresh topic partition leadership every 15 seconds
properties.put("sasl.jaas.config", jaasCfg);
properties.put("security.protocol", "SASL_PLAINTEXT");
properties.put("sasl.mechanism", "PLAIN");
properties.put("ssl.client.auth", "none"); Also added env variable for
KAKFA_OPTS with jass config location so console consumer can use that login
module.i am running single node kafka (0.10.2) with zookeeper (3.4.9). with
these setting both broker and zookeeper comes up.But clients with valid
credential not able to write/read from the broker.pretty much used steps in
documentation from apache Kafka.Pls advice?
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
