Will not attempt to authenticate using SASL (unknown error)

zaqwsxa commented 7 years ago

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?

GZ315200 commented 7 years ago

so do i

fantine16 commented 7 years ago

so do i

Dougoc commented 7 years ago

so do i

prasanjit- commented 6 years ago

so do i :)

coolspring1293 commented 6 years ago

so do i

mrromadon commented 6 years ago

so do i 👍

csarora commented 6 years ago

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)

RymMichaut commented 6 years ago

So do I but with Zookeeper and Druid

boisde commented 6 years ago

So do I.

sashati commented 6 years ago

So do I in Druid for Zookeeper cluster

mohithg commented 6 years ago

Any updates here?

karakasli commented 6 years ago

So do I?

xmzDesign commented 6 years ago

So do I.

melwynjensen commented 6 years ago

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.

ZeinabAshjaei commented 6 years ago

So do I.

swapneeldatta commented 6 years ago

So do I

pulyavin commented 6 years ago

So do I

AftabVirtual commented 6 years ago

So do I

pulyavin commented 6 years ago

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

musclehi commented 5 years ago

so do i

arumoy commented 5 years ago

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?