(inlong) branch master updated: [INLONG-10425][Manager] Fix the problem of the kafka sink defines duplicate attributes (#10426)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 89699deee5 [INLONG-10425][Manager] Fix the problem of the kafka sink 
defines duplicate attributes (#10426)
89699deee5 is described below

commit 89699deee58efd455d5f92d1175cc92a382b3ffd
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Sat Jun 15 23:52:54 2024 +0800

    [INLONG-10425][Manager] Fix the problem of the kafka sink defines duplicate 
attributes (#10426)
---
 .../java/org/apache/inlong/manager/pojo/sink/kafka/KafkaSink.java    | 5 -----
 .../org/apache/inlong/manager/pojo/sink/kafka/KafkaSinkRequest.java  | 5 -----
 2 files changed, 10 deletions(-)

diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/kafka/KafkaSink.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/kafka/KafkaSink.java
index 4e9f3f353e..15e212d578 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/kafka/KafkaSink.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/kafka/KafkaSink.java
@@ -31,8 +31,6 @@ import lombok.EqualsAndHashCode;
 import lombok.ToString;
 import lombok.experimental.SuperBuilder;
 
-import java.util.Map;
-
 /**
  * Kafka sink info
  */
@@ -63,9 +61,6 @@ public class KafkaSink extends StreamSink {
     @ApiModelProperty("Primary key is required when serializationType is json, 
avro")
     private String primaryKey;
 
-    @ApiModelProperty("Properties for kafka")
-    private Map<String, Object> properties;
-
     public KafkaSink() {
         this.setSinkType(SinkType.KAFKA);
     }
diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/kafka/KafkaSinkRequest.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/kafka/KafkaSinkRequest.java
index 387d24e6c5..899fba146a 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/kafka/KafkaSinkRequest.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/kafka/KafkaSinkRequest.java
@@ -28,8 +28,6 @@ import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.ToString;
 
-import java.util.Map;
-
 /**
  * Kafka sink request.
  */
@@ -58,7 +56,4 @@ public class KafkaSinkRequest extends SinkRequest {
     @ApiModelProperty("Primary key is required when serializationType is json, 
avro")
     private String primaryKey;
 
-    @ApiModelProperty("Properties for kafka")
-    private Map<String, Object> properties;
-
 }