From ea08d0dd29750b0af25c6d8c3cf14f976848eb6f Mon Sep 17 00:00:00 2001 From: Nikolay Date: Thu, 23 Feb 2023 05:23:59 +0300 Subject: [PATCH] MINOR: Adjust logging with ZK log format (#13281) This PR adjust Kafka log format with ZK by printing ZK session id in hex format like ZK do. Reviewers: Luke Chen --- core/src/main/scala/kafka/zk/KafkaZkClient.scala | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/zk/KafkaZkClient.scala b/core/src/main/scala/kafka/zk/KafkaZkClient.scala index f4fbaa116c83..78dda799f17d 100644 --- a/core/src/main/scala/kafka/zk/KafkaZkClient.scala +++ b/core/src/main/scala/kafka/zk/KafkaZkClient.scala @@ -43,6 +43,7 @@ import org.apache.zookeeper.common.ZKConfig import org.apache.zookeeper.data.{ACL, Stat} import org.apache.zookeeper.{CreateMode, KeeperException, OpResult, ZooKeeper} +import java.lang.{Long => JLong} import scala.collection.{Map, Seq, mutable} sealed trait KRaftRegistrationResult @@ -2176,12 +2177,12 @@ class KafkaZkClient private[zk] (zooKeeperClient: ZooKeeperClient, isSecure: Boo // be deleted. case Code.OK if shouldReCreateEphemeralZNode(ephemeralOwnerId) => info(s"Was not possible to create the ephemeral at $path, node already exists and owner " + - s"'$ephemeralOwnerId' does not match current session '${zooKeeperClient.sessionId}'" + + s"'0x${JLong.toHexString(ephemeralOwnerId)}' does not match current session '0x${JLong.toHexString(zooKeeperClient.sessionId)}'" + s", trying to delete and re-create it with the newest Zookeeper session") reCreate() case Code.OK if ephemeralOwnerId != zooKeeperClient.sessionId => error(s"Error while creating ephemeral at $path, node already exists and owner " + - s"'$ephemeralOwnerId' does not match current session '${zooKeeperClient.sessionId}'") + s"'0x${JLong.toHexString(ephemeralOwnerId)}' does not match current session '0x${JLong.toHexString(zooKeeperClient.sessionId)}'") throw KeeperException.create(Code.NODEEXISTS) case Code.OK => getDataResponse.stat