CMAK icon indicating copy to clipboard operation
CMAK copied to clipboard

Will not attempt to authenticate using SASL (unknown error)

Open zaqwsxa opened this issue 7 years ago • 48 comments

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?

zaqwsxa avatar Jun 06 '17 09:06 zaqwsxa

so do i

GZ315200 avatar Jun 16 '17 10:06 GZ315200

so do i

fantine16 avatar Nov 01 '17 03:11 fantine16

so do i

Dougoc avatar Nov 13 '17 13:11 Dougoc

so do i :)

prasanjit- avatar Jan 15 '18 19:01 prasanjit-

so do i

coolspring1293 avatar Jan 23 '18 03:01 coolspring1293

so do i 👍

mrromadon avatar Feb 06 '18 08:02 mrromadon

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)

csarora avatar Feb 16 '18 12:02 csarora

So do I but with Zookeeper and Druid

RymMichaut avatar Jun 07 '18 08:06 RymMichaut

So do I.

boisde avatar Jun 12 '18 02:06 boisde

So do I in Druid for Zookeeper cluster

sashati avatar Jun 27 '18 12:06 sashati

Any updates here?

mohithg avatar Jul 04 '18 06:07 mohithg

So do I?

karakasli avatar Aug 06 '18 12:08 karakasli

So do I.

xmzDesign avatar Aug 17 '18 04:08 xmzDesign

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.

melwynjensen avatar Aug 27 '18 15:08 melwynjensen

So do I.

ZeinabAshjaei avatar Aug 27 '18 15:08 ZeinabAshjaei

So do I

swapneeldatta avatar Sep 06 '18 09:09 swapneeldatta

So do I

pulyavin avatar Sep 10 '18 17:09 pulyavin

So do I

AftabVirtual avatar Sep 13 '18 11:09 AftabVirtual

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

pulyavin avatar Sep 13 '18 12:09 pulyavin

so do i

musclehi avatar Nov 15 '18 06:11 musclehi

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?

arumoy avatar Feb 06 '19 13:02 arumoy

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.

MagicJohnJang avatar Mar 26 '19 03:03 MagicJohnJang

so do i :slightly_smiling_face:

mhorne avatar Jul 06 '19 21:07 mhorne

So do I.

MCKad avatar Sep 02 '19 12:09 MCKad

so do i

subatheesh avatar Sep 10 '19 15:09 subatheesh

俺也一样!

sl2026 avatar Jan 15 '20 06:01 sl2026

俺也一样

realzhangqingwei avatar Mar 21 '20 06:03 realzhangqingwei

私は同じです

PeiyuanQi avatar Apr 13 '20 22:04 PeiyuanQi

so do i

Maxtaoge avatar Apr 27 '20 06:04 Maxtaoge

so do i

JonnyLewis avatar Jun 21 '20 18:06 JonnyLewis