From fd938b4466b1e063dc0a4c6e977cc7ef9160c4c9 Mon Sep 17 00:00:00 2001
From: Kondaka <krishkdk@amazon.com>
Date: Tue, 10 Oct 2023 15:38:27 -0700
Subject: [PATCH] Removed unnecessary imports

Signed-off-by: Kondaka <krishkdk@amazon.com>
---
 .../dataprepper/plugins/kafka/source/KafkaSource.java          | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/source/KafkaSource.java b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/source/KafkaSource.java
index fdcfaedf9f..52881e238b 100644
--- a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/source/KafkaSource.java
+++ b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/source/KafkaSource.java
@@ -10,10 +10,7 @@
 import io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient;
 import io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException;
 import io.confluent.kafka.serializers.KafkaAvroDeserializer;
-import io.confluent.kafka.serializers.KafkaAvroDeserializerConfig;
-import io.confluent.kafka.serializers.KafkaJsonDeserializer;
 import io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializer;
-import io.confluent.kafka.serializers.KafkaJsonDeserializerConfig;
 import kafka.common.BrokerEndPointNotAvailableException;
 import org.apache.avro.generic.GenericRecord;
 import org.apache.commons.lang3.StringUtils;