Skip to content

Commit 379da30

Browse files
authored
[Improve][Connector-V2][Kafka]Improve kafka metadata code format (#3397)
1 parent 1c10aac commit 379da30

File tree

1 file changed

+3
-71
lines changed
  • seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source

1 file changed

+3
-71
lines changed

seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/ConsumerMetadata.java

Lines changed: 3 additions & 71 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919

2020
import org.apache.seatunnel.connectors.seatunnel.kafka.config.StartMode;
2121

22+
import lombok.Data;
2223
import org.apache.kafka.common.TopicPartition;
2324

2425
import java.io.Serializable;
@@ -28,6 +29,8 @@
2829
/**
2930
* Kafka consumer metadata, include topic, bootstrap server etc.
3031
*/
32+
33+
@Data
3134
public class ConsumerMetadata implements Serializable {
3235

3336
private String topic;
@@ -40,75 +43,4 @@ public class ConsumerMetadata implements Serializable {
4043
private Map<TopicPartition, Long> specificStartOffsets;
4144
private Long startOffsetsTimestamp;
4245

43-
public boolean isCommitOnCheckpoint() {
44-
return commitOnCheckpoint;
45-
}
46-
47-
public void setCommitOnCheckpoint(boolean commitOnCheckpoint) {
48-
this.commitOnCheckpoint = commitOnCheckpoint;
49-
}
50-
51-
public String getTopic() {
52-
return topic;
53-
}
54-
55-
public void setTopic(String topic) {
56-
this.topic = topic;
57-
}
58-
59-
public boolean isPattern() {
60-
return isPattern;
61-
}
62-
63-
public void setPattern(boolean pattern) {
64-
isPattern = pattern;
65-
}
66-
67-
public String getBootstrapServers() {
68-
return bootstrapServers;
69-
}
70-
71-
public void setBootstrapServers(String bootstrapServers) {
72-
this.bootstrapServers = bootstrapServers;
73-
}
74-
75-
public Properties getProperties() {
76-
return properties;
77-
}
78-
79-
public void setProperties(Properties properties) {
80-
this.properties = properties;
81-
}
82-
83-
public String getConsumerGroup() {
84-
return consumerGroup;
85-
}
86-
87-
public void setConsumerGroup(String consumerGroup) {
88-
this.consumerGroup = consumerGroup;
89-
}
90-
91-
public StartMode getStartMode() {
92-
return startMode;
93-
}
94-
95-
public void setStartMode(StartMode startMode) {
96-
this.startMode = startMode;
97-
}
98-
99-
public Map<TopicPartition, Long> getSpecificStartOffsets() {
100-
return specificStartOffsets;
101-
}
102-
103-
public void setSpecificStartOffsets(Map<TopicPartition, Long> specificStartOffsets) {
104-
this.specificStartOffsets = specificStartOffsets;
105-
}
106-
107-
public Long getStartOffsetsTimestamp() {
108-
return startOffsetsTimestamp;
109-
}
110-
111-
public void setStartOffsetsTimestamp(Long startOffsetsTimestamp) {
112-
this.startOffsetsTimestamp = startOffsetsTimestamp;
113-
}
11446
}

0 commit comments

Comments
 (0)