From 605dc676513e3a312ec3fca340b6ae47976f2d22 Mon Sep 17 00:00:00 2001
From: Mahan Zendedel DH <mahanmmi@gmail.com>
Date: Tue, 9 Jan 2024 20:37:25 +0400
Subject: [PATCH] feat: remove kafka package from utils

---
 pkg/pipeline/sender.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pkg/pipeline/sender.go b/pkg/pipeline/sender.go
index 92f84d2..05544d0 100644
--- a/pkg/pipeline/sender.go
+++ b/pkg/pipeline/sender.go
@@ -72,7 +72,7 @@ func sendToPipelineIndividually(ingestionPipelineEndpoint string, resourcesToSen
 	return nil
 }
 
-func SendToPipeline(ingestionPipelineEndpoint string, resourcesToSend []doc.Doc) error {
+func SendToPipeline(ingestionPipelineEndpoint string, resourcesToSend []es.Doc) error {
 	httpClient := &http.Client{Timeout: 10 * time.Second}
 	if len(resourcesToSend) == 0 {
 		return nil