refactor:Allow vectors to be null (#5)

qdrant · Sep 17, 2024 · a780369 · a780369
1 parent 66450ce
commit a780369
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -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();
     }