From 0307010d468f84d7a91a324a245d593eff7d5044 Mon Sep 17 00:00:00 2001 From: varnit goyal Date: Thu, 9 Jan 2025 16:17:56 +0530 Subject: [PATCH] TP-5555 | error publishing kafka error remove --- pkg/jobs/jobScheduler.go | 1 - service/ExceptionService.go | 2 -- 2 files changed, 3 deletions(-) diff --git a/pkg/jobs/jobScheduler.go b/pkg/jobs/jobScheduler.go index d849bc2..33c1a19 100644 --- a/pkg/jobs/jobScheduler.go +++ b/pkg/jobs/jobScheduler.go @@ -47,7 +47,6 @@ func esCleanUpJob(s *JobScheduler) { rangeQuery := utils.CreateRangeQueryForLteString("created_at", sevenDaysAgo) search_query := utils.CreateSearchQuery(rangeQuery) es_query := utils.CreateEsQuery(search_query) - println("final query %v", es_query) s.elasticSearchClient.DeleteDocuments(es_query) } diff --git a/service/ExceptionService.go b/service/ExceptionService.go index 6e79616..cae78d9 100644 --- a/service/ExceptionService.go +++ b/service/ExceptionService.go @@ -13,7 +13,6 @@ import ( "cybertron/pkg/metrics" "cybertron/pkg/utils" "encoding/json" - "fmt" "github.com/gin-gonic/gin" "gorm.io/gorm" "net/http" @@ -145,7 +144,6 @@ func (exceptionService *ExceptionService) CatchErrors(c *gin.Context) { if err != nil { exceptionService.logger.Error("Error publishing exception to Kafka: " + err.Error()) - fmt.Println("Failed to push error to kafka") } }