(seatunnel) branch dev updated: [Feature][Connector-V2] Remove useless code for kafka connector (#6157)

[gaojun2048]

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new 0f286d1627 [Feature][Connector-V2] Remove useless code for kafka 
connector (#6157)
0f286d1627 is described below

commit 0f286d16272c22bf91db5e8d26078f1f65284f73
Author: Carl-Zhou-CN <1058249...@qq.com>
AuthorDate: Mon Jan 8 18:20:23 2024 +0800

    [Feature][Connector-V2] Remove useless code for kafka connector (#6157)
---
 .../connectors/seatunnel/kafka/source/KafkaSourceReader.java      | 8 --------
 1 file changed, 8 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceReader.java
 
b/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceReader.java
index a2d3bae2b4..252bd0746e 100644
--- 
a/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceReader.java
+++ 
b/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceReader.java
@@ -31,9 +31,7 @@ import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.apache.kafka.clients.consumer.ConsumerRecords;
 import org.apache.kafka.clients.consumer.OffsetAndMetadata;
 import org.apache.kafka.common.TopicPartition;
-import org.apache.kafka.common.serialization.StringDeserializer;
 
-import com.google.common.collect.Maps;
 import com.google.common.collect.Sets;
 import lombok.extern.slf4j.Slf4j;
 
@@ -129,12 +127,6 @@ public class KafkaSourceReader implements 
SourceReader<SeaTunnelRow, KafkaSource
                                                 Set<TopicPartition> partitions 
=
                                                         Sets.newHashSet(
                                                                 
sourceSplit.getTopicPartition());
-                                                StringDeserializer 
stringDeserializer =
-                                                        new 
StringDeserializer();
-                                                stringDeserializer.configure(
-                                                        Maps.fromProperties(
-                                                                
this.metadata.getProperties()),
-                                                        false);
                                                 consumer.assign(partitions);
                                                 if 
(sourceSplit.getStartOffset() >= 0) {
                                                     consumer.seek(