refactor: Use empty named vectors if vectors are omitted (#4)

qdrant · Sep 17, 2024 · 66450ce · 66450ce
1 parent f986a7d
commit 66450ce
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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);