This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-kafka-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 6c4852e [Fix] ignore schema api response (#77)
6c4852e is described below
commit 6c4852ebf4e6f2e97a5a3405e07ffc5cdc134c72
Author: wudi <[email protected]>
AuthorDate: Mon Jun 30 10:56:03 2025 +0800
[Fix] ignore schema api response (#77)
---
.../doris/kafka/connector/model/doris/Field.java | 2 ++
.../doris/kafka/connector/model/doris/Schema.java | 2 ++
.../kafka/connector/converter/TestRecordService.java | 18 ++++++++++++++++++
3 files changed, 22 insertions(+)
diff --git
a/src/main/java/org/apache/doris/kafka/connector/model/doris/Field.java
b/src/main/java/org/apache/doris/kafka/connector/model/doris/Field.java
index 881a4a9..f7c5485 100644
--- a/src/main/java/org/apache/doris/kafka/connector/model/doris/Field.java
+++ b/src/main/java/org/apache/doris/kafka/connector/model/doris/Field.java
@@ -19,9 +19,11 @@
package org.apache.doris.kafka.connector.model.doris;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.Objects;
+@JsonIgnoreProperties(ignoreUnknown = true)
public class Field {
@JsonProperty(value = "name")
private String name;
diff --git
a/src/main/java/org/apache/doris/kafka/connector/model/doris/Schema.java
b/src/main/java/org/apache/doris/kafka/connector/model/doris/Schema.java
index be29b3e..d224820 100644
--- a/src/main/java/org/apache/doris/kafka/connector/model/doris/Schema.java
+++ b/src/main/java/org/apache/doris/kafka/connector/model/doris/Schema.java
@@ -19,10 +19,12 @@
package org.apache.doris.kafka.connector.model.doris;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
+@JsonIgnoreProperties(ignoreUnknown = true)
public class Schema {
private int status = 0;
private String keysType;
diff --git
a/src/test/java/org/apache/doris/kafka/connector/converter/TestRecordService.java
b/src/test/java/org/apache/doris/kafka/connector/converter/TestRecordService.java
index da6d2af..9b578ee 100644
---
a/src/test/java/org/apache/doris/kafka/connector/converter/TestRecordService.java
+++
b/src/test/java/org/apache/doris/kafka/connector/converter/TestRecordService.java
@@ -326,6 +326,24 @@ public class TestRecordService {
new ObjectMapper().writeValueAsString(objectNode));
}
+ @Test
+ public void testFeResponseToSchemaNotMap() throws Exception {
+ String schemaStr =
+
"{\"keysType_notExist\":\"UNIQUE_KEYS\",\"properties\":[{\"name\":\"id\",
\"noExistField\":\"test\",
\"aggregation_type\":\"\",\"comment\":\"\",\"type\":\"BIGINT\"},{\"name\":\"name\",\"aggregation_type\":\"NONE\",\"comment\":\"\",\"type\":\"VARCHAR\"},{\"name\":\"age\",\"aggregation_type\":\"NONE\",\"comment\":\"\",\"type\":\"INT\"},{\"name\":\"email\",\"aggregation_type\":\"NONE\",\"comment\":\"\",\"type\":\"VARCHAR\"},{\"name\":\"birth_date\",\"aggregation_type\":\"NON
[...]
+ Schema schema = null;
+ try {
+ schema = objectMapper.readValue(schemaStr, Schema.class);
+ } catch (JsonProcessingException e) {
+ throw new DorisException(e);
+ }
+ mockRestService
+ .when(() -> RestService.getSchema(any(), any(), any(), any()))
+ .thenReturn(schema);
+
+ Assert.assertNull(schema.getKeysType());
+ Assert.assertEquals(16, schema.getProperties().size());
+ }
+
@After
public void close() {
mockRestService.close();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
