diff --git a/core/redis-kafka-connect/src/main/java/com/redis/kafka/connect/sink/RedisSinkTask.java b/core/redis-kafka-connect/src/main/java/com/redis/kafka/connect/sink/RedisSinkTask.java
index e4bb61a..882020e 100644
--- a/core/redis-kafka-connect/src/main/java/com/redis/kafka/connect/sink/RedisSinkTask.java
+++ b/core/redis-kafka-connect/src/main/java/com/redis/kafka/connect/sink/RedisSinkTask.java
@@ -334,6 +334,9 @@ private Map<byte[], byte[]> map(SinkRecord sinkRecord) {
             }
             return body;
         }
+        if (value == null) {
+			return Collections.emptyMap();
+    	}
         throw new ConnectException("Unsupported source value type: " + sinkRecord.valueSchema().type().name());
     }
 
diff --git a/gradle.properties b/gradle.properties
index e64ec69..d50ca67 100644
--- a/gradle.properties
+++ b/gradle.properties
@@ -38,4 +38,4 @@ org.gradle.daemon           = false
 org.gradle.caching          = false
 org.gradle.parallel         = false
 systemProp.file.encoding    = utf-8
-org.gradle.jvmargs          = -Dfile.encoding=UTF-8
\ No newline at end of file
+org.gradle.jvmargs          = -Dfile.encoding=UTF-8