diff --git a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/InternalServerCnx.java b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/InternalServerCnx.java
index fad9110775..98b5d7e096 100644
--- a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/InternalServerCnx.java
+++ b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/InternalServerCnx.java
@@ -66,6 +66,7 @@ public void closeProducer(Producer producer) {
     // called after channel active
     public void updateCtx() {
         this.remoteAddress = kafkaRequestHandler.getRemoteAddress();
+        this.ctx = kafkaRequestHandler.ctx;
     }
 
     @Override
@@ -115,4 +116,13 @@ public void setMessagePublishBufferSize(long size) {
         this.kopMessagePublishBufferSize = size;
     }
 
+    @Override
+    public boolean equals(Object o) {
+        return super.equals(o);
+    }
+
+    @Override
+    public int hashCode() {
+        return super.hashCode();
+    }
 }
diff --git a/pom.xml b/pom.xml
index 37c9df5b7e..754daac17c 100644
--- a/pom.xml
+++ b/pom.xml
@@ -47,7 +47,7 @@
     <log4j2.version>2.13.3</log4j2.version>
     <lombok.version>1.18.4</lombok.version>
     <mockito.version>2.22.0</mockito.version>
-    <pulsar.version>2.7.2.6</pulsar.version>
+    <pulsar.version>2.7.3.8-rc-3</pulsar.version>
     <slf4j.version>1.7.25</slf4j.version>
     <spotbugs-annotations.version>3.1.8</spotbugs-annotations.version>
     <testcontainers.version>1.15.1</testcontainers.version>