diff --git a/lib/RequestHandler_test.go b/lib/RequestHandler_test.go
new file mode 100644
index 0000000..55c21f8
--- /dev/null
+++ b/lib/RequestHandler_test.go
@@ -0,0 +1 @@
+package lib
diff --git a/main.go b/main.go
index 5f9d771..eb70fb9 100644
--- a/main.go
+++ b/main.go
@@ -8,6 +8,7 @@ import (
 	"com.navi.medici.janus/server"
 	"com.navi.medici.janus/utils"
 	"go.uber.org/zap"
+	"log"
 
 	"github.com/spf13/viper"
 )
@@ -21,11 +22,11 @@ var (
 const metrics_port = "4000"
 
 func init() {
-	utils.InitializeLogger()
-	logger = utils.GetLogger()
 	configs := getConfigs()
+	utils.InitializeLogger(configs.Env)
+	logger = utils.GetLogger()
 	port = configs.Server.Port
-	logger.Debug("PORT IS: %v" + port)
+	logger.Debug("PORT IS: " + port)
 	logger.Debug(configs.Kafka.Bootstrap_Servers)
 	logger.Debug(configs.SchemaRegistry.Endpoint)
 	schema.InitializeSchemaHandler(configs)
@@ -48,12 +49,12 @@ func getConfigs() config.Configurations {
 
 	var configuration config.Configurations
 	if err := viper.ReadInConfig(); err != nil {
-		logger.Fatal("Error reading config file, %v", zap.String("error", err.Error()))
+		log.Fatalf("Error reading config file, %s\n", err)
 	}
 
 	err := viper.Unmarshal(&configuration)
 	if err != nil {
-		logger.Fatal("Unable to decode into struct, %v", zap.String("error", err.Error()))
+		log.Fatalf("Unable to decode into struct, %v\n", err)
 	}
 
 	// Following coinfigurations read from environment variables
diff --git a/producer/producer_client.go b/producer/producer_client.go
index a7ad854..c4fa093 100644
--- a/producer/producer_client.go
+++ b/producer/producer_client.go
@@ -3,12 +3,9 @@ package producer
 import (
 	"com.navi.medici.janus/config"
 	"com.navi.medici.janus/utils"
-	"go.uber.org/zap"
-	"log"
-
 	"crypto/tls"
 	"github.com/Shopify/sarama"
-	"os"
+	"go.uber.org/zap"
 	"strings"
 	"time"
 )
@@ -101,7 +98,6 @@ func GetAsyncProducer(kafkaConfiguration config.KafkaConfigurations, env string)
 }
 
 func InitializeProducers(kafkaConfiguration config.KafkaConfigurations, env string) {
-	sarama.Logger = log.New(os.Stdout, "[sarama] ", log.LstdFlags)
 	logger = utils.GetLogger()
 	syncProducer = GetSyncProducer(kafkaConfiguration, env)
 	asyncProducer = GetAsyncProducer(kafkaConfiguration, env)
diff --git a/utils/logger.go b/utils/logger.go
index 9445d33..6b41676 100644
--- a/utils/logger.go
+++ b/utils/logger.go
@@ -7,9 +7,13 @@ import (
 
 var logger *zap.Logger
 
-func InitializeLogger() {
+func InitializeLogger(env string) {
 	var init_err error
-	logger, init_err = zap.NewProduction()
+	if env == "dev" {
+		logger, init_err = zap.NewDevelopment()
+	} else {
+		logger, init_err = zap.NewProduction()
+	}
 	if init_err != nil {
 		log.Fatal("failed to initialize logger")
 	}