Cmak: Will not attempt to authenticate using SASL (unknown error)

Created on 6 Jun 2017  ·  39Comments  ·  Source: yahoo/CMAK

kafka's are in cluster between 2 servers on this server I have 3 instances kafka with different port
IOS: oracle linux 4.1.12-61.1.18.el7uek.x86_64

  • kafka conf/server.properties
    added:
    host.name=x.x.x.x
    zookeeper.connect=x.x.x.x:6081,x.x.x.x:6081
    other things are basic configuraton

  • kafka conf/zookeeper.properties
    changed data dir
    custer zookeeper
    server.3=x.x.x.x:6088:6089
    server.4=x.x.x.x:6088:6089

also I added a file with myid (each instances has diffrent number)

  • kafka manager config
    only changed
    kafka-manager.zkhosts="x.x.x.x:6081"

How I'm running kafka manager
./bin/kafka-manager -Dconfig.file=conf/application.conf -Dkafka-manager.zkhosts="x.x.x.x:6081" -Dhttp.port=80

  • kafka manager logs

[info] o.a.z.ZooKeeper - Client environment:user.dir=/app/kafka-manager-1.3.3.4
[info] o.a.z.ZooKeeper - Initiating client connection, connectString=x.x.x.x:6081 sessionTimeout=60000 watcher=org.apache.curator.ConnectionState@75973366
[info] o.a.z.ClientCnxn - Opening socket connection to server x.x.x.x/x.x.x.x:6081. Will not attempt to authenticate using SASL (unknown error)
[info] o.a.z.ClientCnxn - Socket connection established to x.x.x.x/x.x.x.x:6081, initiating session
[info] o.a.z.ClientCnxn - Unable to read additional data from server sessionid 0x0, likely server has closed socket, closing socket connection and attempting reconnect
[info] k.m.a.KafkaManagerActor - zk=x.x.x.x:6081
[info] k.m.a.KafkaManagerActor - baseZkPath=/kafka-manager
[info] play.api.Play - Application started (Prod)
[info] p.c.s.NettyServer - Listening for HTTP on /0:0:0:0:0:0:0:0:80
[info] o.a.z.ClientCnxn - Opening socket connection to server x.x.x.x/x.x.x.x:6081. Will not attempt to authenticate using SASL (unknown error)
[info] o.a.z.ClientCnxn - Socket connection established to x.x.x.x/x.x.x.x:6081, initiating session
[info] o.a.z.ClientCnxn - Unable to read additional data from server sessionid 0x0, likely server has closed socket, closing socket connection and attempting reconnect
[info] o.a.z.ClientCnxn - Opening socket connection to server x.x.x.x/x.x.x.x:6081. Will not attempt to authenticate using SASL (unknown error)
[info] o.a.z.ClientCnxn - Socket connection established to x.x.x.x/x.x.x.x:6081, initiating session
[info] o.a.z.ClientCnxn - Unable to read additional data from server sessionid 0x0, likely server has closed socket, closing socket connection and attempting reconnect
[info] o.a.z.ClientCnxn - Opening socket connection to server x.x.x.x/x.x.x.x:6081. Will not attempt to authenticate using SASL (unknown error)
[info] o.a.z.ClientCnxn - Socket connection established to x.x.x.x/x.x.x.x:6081, initiating session
[info] o.a.z.ClientCnxn - Unable to read additional data from server sessionid 0x0, likely server has closed socket, closing socket connection and attempting reconnect
[info] o.a.z.ClientCnxn - Opening socket connection to server x.x.x.x/x.x.x.x:6081. Will not attempt to authenticate using SASL (unknown error)
[info] o.a.z.ClientCnxn - Socket connection established to x.x.x.x/x.x.x.x:6081, initiating session
[info] o.a.z.ClientCnxn - Unable to read additional data from server sessionid 0x0, likely server has closed socket, closing socket connection and attempting reconnect
[info] o.a.z.ClientCnxn - Opening socket connection to server x.x.x.x/x.x.x.x:6081. Will not attempt to authenticate using SASL (unknown error)
[info] o.a.z.ClientCnxn - Socket connection established to x.x.x.x/x.x.x.x:6081, initiating session
[info] o.a.z.ClientCnxn - Unable to read additional data from server sessionid 0x0, likely server has closed socket, closing socket connection and attempting reconnect
[error] k.m.ApiError$ - error : Ask timed out on [ActorSelection[Anchor(akka://kafka-manager-system/), Path(/user/kafka-manager)]] after [5000 ms]
akka.pattern.AskTimeoutException: Ask timed out on [ActorSelection[Anchor(akka://kafka-manager-system/), Path(/user/kafka-manager)]] after [5000 ms]
at akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:334) ~[com.typesafe.akka.akka-actor_2.11-2.3.14.jar:na]
at akka.actor.Scheduler$$anon$7.run(Scheduler.scala:117) ~[com.typesafe.akka.akka-actor_2.11-2.3.14.jar:na]
at scala.concurrent.Future$InternalCallbackExecutor$.unbatchedExecute(Future.scala:601) ~[org.scala-lang.scala-library-2.11.8.jar:na]
at scala.concurrent.BatchingExecutor$class.execute(BatchingExecutor.scala:109) ~[org.scala-lang.scala-library-2.11.8.jar:na]
at scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:599) ~[org.scala-lang.scala-library-2.11.8.jar:na]
at akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(Scheduler.scala:467) ~[com.typesafe.akka.akka-actor_2.11-2.3.14.jar:na]
at akka.actor.LightArrayRevolverScheduler$$anon$8.executeBucket$1(Scheduler.scala:419) ~[com.typesafe.akka.akka-actor_2.11-2.3.14.jar:na]
at akka.actor.LightArrayRevolverScheduler$$anon$8.nextTick(Scheduler.scala:423) ~[com.typesafe.akka.akka-actor_2.11-2.3.14.jar:na]
at akka.actor.LightArrayRevolverScheduler$$anon$8.run(Scheduler.scala:375) ~[com.typesafe.akka.akka-actor_2.11-2.3.14.jar:na]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_121]
[info] o.a.z.ClientCnxn - Opening socket connection to server x.x.x.x/x.x.x.x:6081. Will not attempt to authenticate using SASL (unknown error)
[info] o.a.z.ClientCnxn - Socket connection established to x.x.x.x/x.x.x.x:6081, initiating session
[info] o.a.z.ClientCnxn - Unable to read additional data from server sessionid 0x0, likely server has closed socket, closing socket connection and attempting reconnect
[info] o.a.z.ClientCnxn - Opening socket connection to server x.x.x.x/x.x.x.x:6081. Will not attempt to authenticate using SASL (unknown error)
[info] o.a.z.ClientCnxn - Socket connection established to x.x.x.x/x.x.x.x:6081, initiating session
[info] o.a.z.ClientCnxn - Unable to read additional data from server sessionid 0x0, likely server has closed socket, closing socket connection and attempting reconnect
[info] o.a.z.ClientCnxn - Opening socket connection to server x.x.x.x/x.x.x.x:6081. Will not attempt to authenticate using SASL (unknown error)
[info] o.a.z.ClientCnxn - Socket connection established to x.x.x.x/x.x.x.x:6081, initiating session
[info] o.a.z.ClientCnxn - Unable to read additional data from server sessionid 0x0, likely server has closed socket, closing socket connection and attempting reconnect
[info] o.a.z.ClientCnxn - Opening socket connection to server x.x.x.x/x.x.x.x:6081. Will not attempt to authenticate using SASL (unknown error)
[info] o.a.z.ClientCnxn - Socket connection established to x.x.x.x/x.x.x.x:6081, initiating session
[info] o.a.z.ClientCnxn - Unable to read additional data from server sessionid 0x0, likely server has closed socket, closing socket connection and attempting reconnect
[info] o.a.z.ClientCnxn - Opening socket connection to server x.x.x.x/x.x.x.x:6081. Will not attempt to authenticate using SASL (unknown error)
[info] o.a.z.ClientCnxn - Socket connection established to x.x.x.x/x.x.x.x:6081, initiating session
[info] o.a.z.ClientCnxn - Unable to read additional data from server sessionid 0x0, likely server has closed socket, closing socket connection and attempting reconnect

  • important
  • Other instances on port x.x.x.x:9081 in cluster are working propertly, everything is fine

  • When I'm running other kafka manager on the same network subnet, why they are connecting each other?

Most helpful comment

I set maxClientCnxns=1000 in ZooKeeper conf and it helps me

All 39 comments

so do i

so do i

so do i

so do i :)

so do i

so do i 👍

I am also getting same error, any solution ? works ok when i have one zookeeper server but for more than one zookeeper then Kafka fails with below error:

[2018-02-16 12:32:43,864] INFO Socket connection established to 10.32.0.110/10.32.0.110:2181, initiating session (org.apache.zookeeper.ClientCnxn)
[2018-02-16 12:32:43,866] INFO Unable to read additional data from server sessionid 0x0, likely server has closed socket, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn)
..

2018-02-16 12:32:49,027] FATAL Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to zookeeper server '10.32.0.108:2181,10.32.0.110:2181,10.32.0.111:2181' with timeout of 9000 ms
    at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1233)
    at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:157)
    at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:131)
    at kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:106)
    at kafka.utils.ZkUtils$.apply(ZkUtils.scala:88)
    at kafka.server.KafkaServer.initZk(KafkaServer.scala:326)
    at kafka.server.KafkaServer.startup(KafkaServer.scala:187)
    at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:39)
    at kafka.Kafka$.main(Kafka.scala:67)
    at kafka.Kafka.main(Kafka.scala)
[2018-02-16 12:32:49,030] INFO shutting down (kafka.server.KafkaServer)

So do I but with Zookeeper and Druid

So do I.

So do I in Druid for Zookeeper cluster

Any updates here?

So do I?

So do I.

So do I.

::Update:: Found the issue, it was an internal communication problem with Kafka to Zookeeper as it was not able to reach the node. Reassigned the nodes properly and it was up and running.

So do I.

So do I

So do I

So do I

I set maxClientCnxns=1000 in ZooKeeper conf and it helps me

so do i

So do I.

::Update:: Found the issue, it was an internal communication problem with Kafka to Zookeeper as it was not able to reach the node. Reassigned the nodes properly and it was up and running.

How did you re-assign the nodes?

Finally work!
You got to create a cluster in Zookeeper first, then start Kafka!

Because you give Kafka multiple zookeeper addresses, which means you tell Kafka to connect to a cluster.

so do i :slightly_smiling_face:

So do I.

so do i

俺也一样!

俺也一样

私は同じです

so do i

so do i

俺也一样

俺也一样

so do i

so do i

Same error, still continue in 2021.

Same error, still continue in 2021.

so do i

you are very not good

Same here, any solutions? :)

Was this page helpful?
0 / 5 - 0 ratings