add inputID when creating the pipeline client

elastic · Feb 11, 2025 · 97f4983 · 97f4983
1 parent adfb888
commit 97f4983
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/filebeat/input/v2/input-cursor/input.go b/filebeat/input/v2/input-cursor/input.go
@@ -147,6 +147,7 @@ func (inp *managedInput) runSource(
 	}()
 
 	client, err := pipeline.ConnectWith(beat.ClientConfig{
+		InputID:       ctx.ID,
 		EventListener: newInputACKHandler(ctx.Logger),
 	})
 	if err != nil {

diff --git a/filebeat/input/v2/input-stateless/stateless.go b/filebeat/input/v2/input-stateless/stateless.go
@@ -84,6 +84,7 @@ func (si configuredInput) Run(ctx v2.Context, pipeline beat.PipelineConnector) (
 	}()
 
 	client, err := pipeline.ConnectWith(beat.ClientConfig{
+		InputID:     ctx.ID,
 		PublishMode: beat.DefaultGuarantees,
 	})
 	if err != nil {