Removed Confluent shifting to Sarama

Author: Swap76

go.mod

@@ -4,7 +4,6 @@ go 1.14
 
 require (
 	github.com/caarlos0/env/v6 v6.2.1
-	github.com/confluentinc/confluent-kafka-go v1.4.2
 	github.com/gin-gonic/gin v1.6.2
 	go.mongodb.org/mongo-driver v1.3.2
 	go.uber.org/zap v1.15.0

go.sum

@@ -1,8 +1,6 @@
 github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
 github.com/caarlos0/env/v6 v6.2.1 h1:/bFpX1dg4TNioJjg7mrQaSrBoQvRfLUHNfXivdFbbEo=
 github.com/caarlos0/env/v6 v6.2.1/go.mod h1:3LpmfcAYCG6gCiSgDLaFR5Km1FRpPwFvBbRcjHar6Sw=
-github.com/confluentinc/confluent-kafka-go v1.4.2 h1:13EK9RTujF7lVkvHQ5Hbu6bM+Yfrq8L0MkJNnjHSd4Q=
-github.com/confluentinc/confluent-kafka-go v1.4.2/go.mod h1:u2zNLny2xq+5rWeTQjFHbDzzNuba4P1vo31r9r4uAdg=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/gin-contrib/sse v0.1.0 h1:Y/yl/+YNO8GZSjAhjMsSuLt29uWRFHdHYUb5lYOV9qE=
@@ -107,8 +105,6 @@ go.uber.org/atomic v1.6.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ=
 go.uber.org/multierr v1.5.0 h1:KCa4XfM8CWFCpxXRGok+Q0SS/0XBhMDbHHGABQLvD2A=
 go.uber.org/multierr v1.5.0/go.mod h1:FeouvMocqHpRaaGuG9EjoKcStLC43Zu/fmqdUMPcKYU=
 go.uber.org/tools v0.0.0-20190618225709-2cfd321de3ee/go.mod h1:vJERXedbb3MVM5f9Ejo0C68/HhF8uaILCdgjnY+goOA=
-go.uber.org/zap v1.14.1 h1:nYDKopTbvAPq/NrUVZwT15y2lpROBiLLyoRTbXOYWOo=
-go.uber.org/zap v1.14.1/go.mod h1:Mb2vm2krFEG5DV0W9qcHBYFtp/Wku1cvYaqPsS/WYfc=
 go.uber.org/zap v1.15.0 h1:ZZCA22JRF2gQE5FoNmhmrf7jeJJ2uhqDUNRYKm8dvmM=
 go.uber.org/zap v1.15.0/go.mod h1:Mb2vm2krFEG5DV0W9qcHBYFtp/Wku1cvYaqPsS/WYfc=
 golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=

main.go

@@ -6,7 +6,6 @@ import (
 	"github.com/siesgstarena/epicentre/logger"
 	routes "github.com/siesgstarena/epicentre/router"
 	"github.com/siesgstarena/epicentre/services/mongo"
-	"github.com/siesgstarena/epicentre/services/kafka"
 )
 
 func main() {
@@ -25,27 +24,11 @@ func main() {
 
 	mongo.LoadMongo()
 
-	err = kafka.LoadKafka()
-	if err != nil {
-		panic(err)
-	}
-	logger.Log.Info("Kafka Installed Successfully")
-
 	router := gin.Default()
 
 	routes.LoadRouter(router)
 
 	router.Run(":" + config.Config.Port)
 
-	err = kafka.ProduceMessage("Testing Kafka Implementation")
-	if err != nil {
-		panic(err)
-	}
-
-	err = kafka.ConsumeMessage()
-	if err != nil {
-		panic(err)
-	}
-
 	// defer mongo.Client.Disconnect(*mongo.Ctx)
 }