From ee74da3b0bc8ef86d9df176e21f778e56aeac380 Mon Sep 17 00:00:00 2001
From: Rashmin Patel <rashmin.patel@navi.com>
Date: Wed, 7 Aug 2024 15:54:23 +0530
Subject: [PATCH] DE-1338 | removing schema registry dependency - III

---
 config/config.go | 6 ------
 main.go          | 2 --
 2 files changed, 8 deletions(-)

diff --git a/config/config.go b/config/config.go
index 2d1fe23..4841d7c 100644
--- a/config/config.go
+++ b/config/config.go
@@ -4,7 +4,6 @@ type Configurations struct {
 	Env            string
 	Server         ServerConfigurations
 	Kafka          KafkaConfigurations
-	SchemaRegistry SchemaRegistryConfigurations
 }
 
 type ServerConfigurations struct {
@@ -22,8 +21,3 @@ type KafkaConfigurations struct {
 	Kafka_Topic_Json     string
 	Kafka_Topic_Protobuf string
 }
-
-type SchemaRegistryConfigurations struct {
-	Endpoint string
-	Topics   string
-}
diff --git a/main.go b/main.go
index 9067e03..6813780 100644
--- a/main.go
+++ b/main.go
@@ -52,8 +52,6 @@ func getConfigs() config.Configurations {
 	// Following coinfigurations read from environment variables
 	configuration.Env = viper.GetString(configuration.Env)
 	configuration.Kafka.Bootstrap_Servers = viper.GetString(configuration.Kafka.Bootstrap_Servers)
-	configuration.SchemaRegistry.Endpoint = viper.GetString(configuration.SchemaRegistry.Endpoint)
-	configuration.SchemaRegistry.Topics = viper.GetString(configuration.SchemaRegistry.Topics)
 	configuration.Kafka.Kafka_Topic_Json = viper.GetString(configuration.Kafka.Kafka_Topic_Json)
 	configuration.Kafka.Kafka_Topic_Protobuf = viper.GetString(configuration.Kafka.Kafka_Topic_Protobuf)