diff --git a/src/main/java/io/qdrant/kafka/ValueExtractor.java b/src/main/java/io/qdrant/kafka/ValueExtractor.java
index e4247c5..d5d32ed 100644
--- a/src/main/java/io/qdrant/kafka/ValueExtractor.java
+++ b/src/main/java/io/qdrant/kafka/ValueExtractor.java
@@ -5,6 +5,7 @@
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.google.protobuf.InvalidProtocolBufferException;
 import io.qdrant.client.grpc.JsonWithInt.Value;
+import io.qdrant.client.grpc.Points.NamedVectors;
 import io.qdrant.client.grpc.Points.PointId;
 import io.qdrant.client.grpc.Points.PointStruct;
 import io.qdrant.client.grpc.Points.Vectors;
@@ -77,7 +78,7 @@ public Vectors getVector() {
     Value vectorValue = this.valueMap.get(VECTOR_KEY);
 
     if (vectorValue == null) {
-      return Vectors.getDefaultInstance();
+      return Vectors.newBuilder().setVectors(NamedVectors.getDefaultInstance()).build();
     }
 
     return VectorsFactory.vectors(vectorValue);