From 09beb19ae7141268150862f8d3e751299dcf87a6 Mon Sep 17 00:00:00 2001
From: aishwarya-raimule <aishwarya.raimule@navi.com>
Date: Mon, 30 Jan 2023 17:45:34 +0530
Subject: [PATCH] updated log messages and removed AddSchema function

---
 main.go               |  4 ++--
 schema/schema_util.go | 25 -------------------------
 2 files changed, 2 insertions(+), 27 deletions(-)

diff --git a/main.go b/main.go
index 86e3ef2..178cf83 100644
--- a/main.go
+++ b/main.go
@@ -72,10 +72,10 @@ func main() {
 	httpServer, err1 := server.NewServer(port, cors)
 	metricsServer, err2 := server.MetricServer(METRICS_PORT)
 	if err1 != nil {
-		logger.Fatal("Unable to start server, %v", zap.String("error", err1.Error()))
+		logger.Fatal("Unable to start server, %v", zap.Error(err1))
 	}
 	if err2 != nil {
-		logger.Fatal("Unable to start Metric server, %v", zap.String("error", err2.Error()))
+		logger.Fatal("Unable to start Metric server, %v", zap.Error(err2))
 	}
 	go httpServer.HttpServer.Serve(httpServer.Listener)
 	go metricsServer.HttpServer.Serve(metricsServer.Listener)
diff --git a/schema/schema_util.go b/schema/schema_util.go
index c0bec05..25df622 100644
--- a/schema/schema_util.go
+++ b/schema/schema_util.go
@@ -39,28 +39,3 @@ func GetSchemaVersions() {
 	}
 	logger.Debug("Schema Version Map", zap.String("", fmt.Sprintf("%v", SchemaVersionMap)))
 }
-
-func AddSchema(topic string, schemaType string, schema string) error {
-
-	schemaRegistryClient := srclient.CreateSchemaRegistryClient(SchemaRegistryEndpoint)
-	schemaRegistryClient.CodecCreationEnabled(false)
-	existingSchema, _ := schemaRegistryClient.GetLatestSchema(topic, false)
-	logger.Debug("EXISTINGSCHEMA", zap.String("", fmt.Sprintf("%v", existingSchema)))
-
-	if existingSchema != nil {
-		compatible, errorCompatible := schemaRegistryClient.IsSchemaCompatible(topic, schema, "latest", srclient.SchemaType(schemaType), false)
-		if errorCompatible != nil {
-			return errorCompatible
-		} else if compatible == false {
-			return fmt.Errorf("given schema not compatible with the latest version")
-		}
-	}
-
-	_, errroCreate := schemaRegistryClient.CreateSchema(topic, schema, srclient.SchemaType(schemaType), false)
-
-	if errroCreate != nil {
-		return errroCreate
-	} else {
-		return nil
-	}
-}