diff --git a/build.gradle b/build.gradle
index 6ff4349..5d432b4 100644
--- a/build.gradle
+++ b/build.gradle
@@ -11,7 +11,7 @@ plugins {
 }
 
 group = 'io.qdrant'
-version = '1.1.1'
+version = '1.1.2'
 description = 'Kafka Sink Connector for Qdrant.'
 java.sourceCompatibility = JavaVersion.VERSION_1_8
 java.targetCompatibility = JavaVersion.VERSION_1_8
diff --git a/src/main/java/io/qdrant/kafka/ValueExtractor.java b/src/main/java/io/qdrant/kafka/ValueExtractor.java
index d5d32ed..fcca8b7 100644
--- a/src/main/java/io/qdrant/kafka/ValueExtractor.java
+++ b/src/main/java/io/qdrant/kafka/ValueExtractor.java
@@ -77,7 +77,7 @@ public Map<String, Value> getPayload() {
   public Vectors getVector() {
     Value vectorValue = this.valueMap.get(VECTOR_KEY);
 
-    if (vectorValue == null) {
+    if (vectorValue == null || vectorValue.hasNullValue()) {
       return Vectors.newBuilder().setVectors(NamedVectors.getDefaultInstance()).build();
     }