[incubator-seatunnel] branch dev updated: [Improve][Connector-V2][Kafka]Improve kafka metadata code format (#3397)

[fanjia]

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

fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 379da3097 [Improve][Connector-V2][Kafka]Improve kafka metadata code 
format (#3397)
379da3097 is described below

commit 379da3097f910d1b1ab4142585399d391a9d0abe
Author: TaoZex <45089228+tao...@users.noreply.github.com>
AuthorDate: Sun Nov 13 13:35:18 2022 +0800

    [Improve][Connector-V2][Kafka]Improve kafka metadata code format (#3397)
---
 .../seatunnel/kafka/source/ConsumerMetadata.java   | 74 +---------------------
 1 file changed, 3 insertions(+), 71 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/ConsumerMetadata.java
 
b/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/ConsumerMetadata.java
index 615d89416..12b1365af 100644
--- 
a/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/ConsumerMetadata.java
+++ 
b/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/ConsumerMetadata.java
@@ -19,6 +19,7 @@ package 
org.apache.seatunnel.connectors.seatunnel.kafka.source;
 
 import org.apache.seatunnel.connectors.seatunnel.kafka.config.StartMode;
 
+import lombok.Data;
 import org.apache.kafka.common.TopicPartition;
 
 import java.io.Serializable;
@@ -28,6 +29,8 @@ import java.util.Properties;
 /**
  * Kafka consumer metadata, include topic, bootstrap server etc.
  */
+
+@Data
 public class ConsumerMetadata implements Serializable {
 
     private String topic;
@@ -40,75 +43,4 @@ public class ConsumerMetadata implements Serializable {
     private Map<TopicPartition, Long> specificStartOffsets;
     private Long startOffsetsTimestamp;
 
-    public boolean isCommitOnCheckpoint() {
-        return commitOnCheckpoint;
-    }
-
-    public void setCommitOnCheckpoint(boolean commitOnCheckpoint) {
-        this.commitOnCheckpoint = commitOnCheckpoint;
-    }
-
-    public String getTopic() {
-        return topic;
-    }
-
-    public void setTopic(String topic) {
-        this.topic = topic;
-    }
-
-    public boolean isPattern() {
-        return isPattern;
-    }
-
-    public void setPattern(boolean pattern) {
-        isPattern = pattern;
-    }
-
-    public String getBootstrapServers() {
-        return bootstrapServers;
-    }
-
-    public void setBootstrapServers(String bootstrapServers) {
-        this.bootstrapServers = bootstrapServers;
-    }
-
-    public Properties getProperties() {
-        return properties;
-    }
-
-    public void setProperties(Properties properties) {
-        this.properties = properties;
-    }
-
-    public String getConsumerGroup() {
-        return consumerGroup;
-    }
-
-    public void setConsumerGroup(String consumerGroup) {
-        this.consumerGroup = consumerGroup;
-    }
-
-    public StartMode getStartMode() {
-        return startMode;
-    }
-
-    public void setStartMode(StartMode startMode) {
-        this.startMode = startMode;
-    }
-
-    public Map<TopicPartition, Long> getSpecificStartOffsets() {
-        return specificStartOffsets;
-    }
-
-    public void setSpecificStartOffsets(Map<TopicPartition, Long> 
specificStartOffsets) {
-        this.specificStartOffsets = specificStartOffsets;
-    }
-
-    public Long getStartOffsetsTimestamp() {
-        return startOffsetsTimestamp;
-    }
-
-    public void setStartOffsetsTimestamp(Long startOffsetsTimestamp) {
-        this.startOffsetsTimestamp = startOffsetsTimestamp;
-    }
 }