Fixed Failure of Enhanced Kafka Interceptor to Acquire SkyWalking DynamicField (#2470)

a0ef72cf · Wilt · wu-sheng · 4beaac00 · a0ef72cf
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

apm-sniffer/apm-sdk-plugin/kafka-v1-plugin/src/main/java/org/apache/skywalking/apm/plugin/kafka/v1/CallbackInterceptor.java ...e/skywalking/apm/plugin/kafka/v1/CallbackInterceptor.java +3 -1

未找到文件。
--- a/apm-sniffer/apm-sdk-plugin/kafka-v1-plugin/src/main/java/org/apache/skywalking/apm/plugin/kafka/v1/CallbackInterceptor.java
+++ b/apm-sniffer/apm-sdk-plugin/kafka-v1-plugin/src/main/java/org/apache/skywalking/apm/plugin/kafka/v1/CallbackInterceptor.java
@@ -34,7 +34,9 @@ public class CallbackInterceptor implements InstanceMethodsAroundInterceptor {

        //Get the SnapshotContext
        ContextSnapshot contextSnapshot = (ContextSnapshot)objInst.getSkyWalkingDynamicField();
-        ContextManager.continued(contextSnapshot);
+        if (null != contextSnapshot) {
+            ContextManager.continued(contextSnapshot);
+        }
    }

    @Override