Ramesh Sencha created KAFKA-12745:
-------------------------------------
Summary: Kafka with 2.7.0 version service start failing while
making zookeeper connection calls
Key: KAFKA-12745
URL: https://issues.apache.org/jira/browse/KAFKA-12745
Project: Kafka
Issue Type: Bug
Components: controller, zkclient
Affects Versions: 2.7.0
Environment: production
Reporter: Ramesh Sencha
I have existing Kafka setup working as below -
{code}
{{Kafka - 2.4.1 (3 brokers)}}
{{Zookeeper - 3.6.2 (3 nodes)}}
{code}
{{}}
Now I am upgrading the Kafka version to 2.7.0, but when I downloaded the binary
and trying to start service, it is failing while making the connection with the
zookeeper, it's not giving many error details/trace, only below logs.
{{}}
{{{code}}}
{{INFO Registered kafka:type=kafka.Log4jController MBean
(kafka.utils.Log4jControllerRegistration$)
INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable
client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
INFO Registered signal handlers for TERM, INT, HUP
(org.apache.kafka.common.utils.LoggingSignalHandler)
INFO starting (kafka.server.KafkaServer)
INFO Connecting to zookeeper on
10.1.13.74:2181,10.1.12.213:2181,10.1.11.190:2181 (kafka.server.KafkaServer)
INFO [ZooKeeperClient Kafka server] Initializing a new session to
10.1.13.74:2181,10.1.12.213:2181,10.1.11.190:2181.
(kafka.zookeeper.ZooKeeperClient)
INFO Client
environment:zookeeper.version=3.4.13-2d71af4dbe22557fda74f9a9b4309b15a7487f03,
built on 06/29/2018 00:39 GMT (org.apache.zookeeper.ZooKeeper)
INFO Client environment:host.name=ip-10-1-11-139.ec2.internal
(org.apache.zookeeper.ZooKeeper)
INFO Client environment:java.version=11.0.9.1 (org.apache.zookeeper.ZooKeeper)
INFO Client environment:java.vendor=Red Hat, Inc.
(org.apache.zookeeper.ZooKeeper)
INFO Client
environment:java.home=/usr/lib/jvm/java-11-openjdk-11.0.9.11-2.el7_9.x86_64
(org.apache.zookeeper.ZooKeeper)
...
...
[2021-04-29 11:37:52,874] INFO Client
environment:java.library.path=/usr/java/packages/lib:/usr/lib64:/lib64:/lib:/usr/lib
(org.apache.zookeeper.ZooKeeper)
[2021-04-29 11:37:52,874] INFO Client environment:java.io.tmpdir=/tmp
(org.apache.zookeeper.ZooKeeper)
[2021-04-29 11:37:52,874] INFO Client environment:java.compiler=<NA>
(org.apache.zookeeper.ZooKeeper)
[2021-04-29 11:37:52,874] INFO Client environment:os.name=Linux
(org.apache.zookeeper.ZooKeeper)
[2021-04-29 11:37:52,874] INFO Client environment:os.arch=amd64
(org.apache.zookeeper.ZooKeeper)
[2021-04-29 11:37:52,874] INFO Client
environment:os.version=3.10.0-1160.24.1.el7.x86_64
(org.apache.zookeeper.ZooKeeper)
[2021-04-29 11:37:52,874] INFO Client environment:user.name=kafka
(org.apache.zookeeper.ZooKeeper)
[2021-04-29 11:37:52,874] INFO Client environment:user.home=/home/kafka
(org.apache.zookeeper.ZooKeeper)
[2021-04-29 11:37:52,874] INFO Client
environment:user.dir=/srv/kafka/2.13-2.7.0/kafka_2.13-2.7.0
(org.apache.zookeeper.ZooKeeper)
...
...
ERROR Fatal error during KafkaServer startup. Prepare to shutdown
(kafka.server.KafkaServer)
java.lang.NoSuchMethodError: 'void
org.apache.zookeeper.ZooKeeper.<init>(java.lang.String, int,
org.apache.zookeeper.Watcher, org.apache.zookeeper.client.ZKClientConfig)'
at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:111)
at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1881)
at kafka.server.KafkaServer.createZkClient$1(KafkaServer.scala:441)
at kafka.server.KafkaServer.initZkClient(KafkaServer.scala:466)
at kafka.server.KafkaServer.startup(KafkaServer.scala:233)
at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)
at kafka.Kafka$.main(Kafka.scala:82)
at kafka.Kafka.main(Kafka.scala)
INFO shutting down (kafka.server.KafkaServer)
INFO App info kafka.server for 12 unregistered
(org.apache.kafka.common.utils.AppInfoParser)
INFO shut down completed (kafka.server.KafkaServer)
ERROR Exiting Kafka. (kafka.server.KafkaServerStartable)
INFO shutting down (kafka.server.KafkaServer)
kafka.service: main process exited, code=exited, status=1/FAILURE }}{{}}
{{{code}}}
{{}}
I tried to set logging mode to DEBUG but still not giving much information on
why it's not able to make the connection with the zookeeper, from logs it's
clear that it has initiated a zookeeper connection.
Another thing which I suspect is why it is giving zookeeper version 3.4.13 when
my zookeeper server(which is on another machine) is version 3.6.2
{code}
{{INFO Client
environment:zookeeper.version=3.4.13-2d71af4dbe22557fda74f9a9b4309b15a7487f03,
built on 06/29/2018 00:39 GMT (org.apache.zookeeper.ZooKeeper)}}
{code}
If I switch back to using Kafka 2.4.1 & everything else as is it works fine,
but not sure whats the problem with Kafka version 2.7.x/2.6.x
Any help would be greatly appreciated.
{{}}{{}}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)