Fix usage of Class.getCanonicalName to Class.getName

apache · May 19, 2017 · 93bad0a · 93bad0a
1 parent 2e05711
commit 93bad0a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/Requirements.java b/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/Requirements.java
@@ -55,7 +55,7 @@ public static SinkRecord requireSinkRecord(ConnectRecord<?> record, String purpo
     }
 
     private static String nullSafeClassName(Object x) {
-        return x == null ? "null" : x.getClass().getCanonicalName();
+        return x == null ? "null" : x.getClass().getName();
     }
 
 }