feat: remove kafka package from utils

opengovern · Jan 9, 2024 · 605dc67 · 605dc67
1 parent de8ac66
commit 605dc67
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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