From 871fdf2fa251e3e2c3082a2373e4ead6c4aec8fd Mon Sep 17 00:00:00 2001
From: Jingguo Yao <yaojingguo@gmail.com>
Date: Thu, 4 Mar 2021 11:34:28 +0800
Subject: [PATCH] Remove unnecessary check for getSkyWalkingDynamicField
 invocation (#6480)

---
 .../apm/plugin/kafka/CallbackConstructorInterceptor.java   | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

diff --git a/apm-sniffer/apm-sdk-plugin/kafka-plugin/src/main/java/org/apache/skywalking/apm/plugin/kafka/CallbackConstructorInterceptor.java b/apm-sniffer/apm-sdk-plugin/kafka-plugin/src/main/java/org/apache/skywalking/apm/plugin/kafka/CallbackConstructorInterceptor.java
index 613860ce0..7c13d9ec1 100644
--- a/apm-sniffer/apm-sdk-plugin/kafka-plugin/src/main/java/org/apache/skywalking/apm/plugin/kafka/CallbackConstructorInterceptor.java
+++ b/apm-sniffer/apm-sdk-plugin/kafka-plugin/src/main/java/org/apache/skywalking/apm/plugin/kafka/CallbackConstructorInterceptor.java
@@ -30,12 +30,7 @@ public class CallbackConstructorInterceptor implements InstanceConstructorInterc
     @Override
     public void onConstruct(EnhancedInstance objInst, Object[] allArguments) {
         Callback callback = (Callback) allArguments[0];
-        CallbackCache cache;
-        if (null != objInst.getSkyWalkingDynamicField()) {
-            cache = (CallbackCache) objInst.getSkyWalkingDynamicField();
-        } else {
-            cache = new CallbackCache();
-        }
+        CallbackCache cache = new CallbackCache();
         cache.setCallback(callback);
         objInst.setSkyWalkingDynamicField(cache);
     }