removing Kafka from basket-api

chayxana · Dec 27, 2023 · 3e324ea · 3e324ea
1 parent 71f90fe
commit 3e324ea
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 8 deletions.
diff --git a/src/backend/services/basket-api/cmd/api/main.go b/src/backend/services/basket-api/cmd/api/main.go
@@ -10,7 +10,6 @@ import (
 	"syscall"
 	"time"
 
-	"github.com/Shopify/sarama"
 	"github.com/jurabek/basket.api/cmd/config"
 	"github.com/jurabek/basket.api/internal/database"
 	"github.com/jurabek/basket.api/internal/docs"
@@ -24,7 +23,6 @@ import (
 	"google.golang.org/grpc/reflection"
 
 	"github.com/redis/go-redis/extra/redisotel/v9"
-	"go.opentelemetry.io/contrib/instrumentation/github.com/Shopify/sarama/otelsarama"
 	"go.opentelemetry.io/contrib/instrumentation/github.com/gin-gonic/gin/otelgin"
 	"go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc"
 	"go.opentelemetry.io/otel"
@@ -90,13 +88,13 @@ func main() {
 		fmt.Print(err)
 	}
 
-	p, err := sarama.NewSyncProducer([]string{cfg.KafkaBroker}, nil)
-	if err != nil {
-		log.Fatal().Err(err).Msg("new producer failed!")
-	}
+	// p, err := sarama.NewSyncProducer([]string{cfg.KafkaBroker}, nil)
+	// if err != nil {
+	// 	log.Fatal().Err(err).Msg("new producer failed!")
+	// }
 
-	tracedProducer := otelsarama.WrapSyncProducer(nil, p)
-	defer tracedProducer.Close()
+	// tracedProducer := otelsarama.WrapSyncProducer(nil, p)
+	// defer tracedProducer.Close()
 
 	basketRepository := repositories.NewRedisBasketRepository(redisClient)
 	basketHandler := handlers.NewBasketHandler(basketRepository)

diff --git a/src/backend/services/basket-api/internal/handlers/basket_handler.go b/src/backend/services/basket-api/internal/handlers/basket_handler.go
@@ -25,6 +25,7 @@ func NewBasketHandler(r GetCreateDeleter) *BasketHandler {
 }
 
 // Create go doc
+//
 //	@Summary		Add a CustomerBasket
 //	@Description	add by json new CustomerBasket
 //	@Tags			CustomerBasket
@@ -60,6 +61,7 @@ func (bc *BasketHandler) Create(c *gin.Context) {
 }
 
 // Get go doc
+//
 //	@Summary		Gets a CustomerBasket
 //	@Description	Get CustomerBasket by ID
 //	@Tags			CustomerBasket
@@ -83,6 +85,7 @@ func (bc *BasketHandler) Get(c *gin.Context) {
 }
 
 // Delete go doc
+//
 //	@Summary		Deletes a CustomerBasket
 //	@Description	Deletes CustomerBasket by ID
 //	@Tags			CustomerBasket