diff --git a/pipeline/pipeline_test.go b/pipeline/pipeline_test.go
index f2d8338eb..7dd15571e 100644
--- a/pipeline/pipeline_test.go
+++ b/pipeline/pipeline_test.go
@@ -37,7 +37,7 @@ func TestInUnparsableMessages(t *testing.T) {
 	sourceID := pipeline.SourceID(3<<16 + int(10))
 
 	t.Run(name, func(t *testing.T) {
-		pipe := pipeline.New("test_pipeline", pipelineSettings, prometheus.NewRegistry(), zap.NewNop().Sugar())
+		pipe := pipeline.New("test_pipeline", pipelineSettings, prometheus.NewRegistry(), zap.NewNop())
 
 		pipe.SetInput(getFakeInputInfo())
 
@@ -113,7 +113,7 @@ func TestInInvalidMessages(t *testing.T) {
 
 	for _, tCase := range cases {
 		t.Run(tCase.name, func(t *testing.T) {
-			pipe := pipeline.New("test_pipeline", tCase.pipelineSettings, prometheus.NewRegistry(), zap.NewNop().Sugar())
+			pipe := pipeline.New("test_pipeline", tCase.pipelineSettings, prometheus.NewRegistry(), zap.NewNop())
 
 			pipe.SetInput(getFakeInputInfo())
 
diff --git a/pipeline/pipeline_whitebox_test.go b/pipeline/pipeline_whitebox_test.go
index 3e625966b..0b2720dd7 100644
--- a/pipeline/pipeline_whitebox_test.go
+++ b/pipeline/pipeline_whitebox_test.go
@@ -14,7 +14,7 @@ func TestPipeline_streamEvent(t *testing.T) {
 		Capacity: 5,
 		Decoder:  "json",
 	}
-	p := New("test", settings, prometheus.NewRegistry(), zap.NewNop().Sugar())
+	p := New("test", settings, prometheus.NewRegistry(), zap.NewNop())
 
 	streamID := StreamID(123123)
 	procs := int32(7)
diff --git a/plugin/output/file/helpers_test.go b/plugin/output/file/helpers_test.go
index 1edbd4448..03f2410f3 100644
--- a/plugin/output/file/helpers_test.go
+++ b/plugin/output/file/helpers_test.go
@@ -57,7 +57,7 @@ func newPipeline(t *testing.T, configOutput *Config) *pipeline.Pipeline {
 		Decoder:             "json",
 	}
 
-	p := pipeline.New("test_pipeline", settings, prometheus.NewRegistry(), zap.NewNop().Sugar())
+	p := pipeline.New("test_pipeline", settings, prometheus.NewRegistry(), zap.NewNop())
 	p.DisableParallelism()
 	p.EnableEventLog()
 
diff --git a/plugin/output/s3/s3_test.go b/plugin/output/s3/s3_test.go
index 92476185b..df0771a5a 100644
--- a/plugin/output/s3/s3_test.go
+++ b/plugin/output/s3/s3_test.go
@@ -405,7 +405,7 @@ func newPipeline(t *testing.T, configOutput *Config, objStoreF objStoreFactory)
 		Decoder:           "json",
 	}
 
-	p := pipeline.New("test_pipeline", settings, prometheus.NewRegistry(), zap.NewNop().Sugar())
+	p := pipeline.New("test_pipeline", settings, prometheus.NewRegistry(), zap.NewNop())
 	p.DisableParallelism()
 	p.EnableEventLog()
 
diff --git a/test/test.go b/test/test.go
index 76faf6dc0..ceee145a8 100644
--- a/test/test.go
+++ b/test/test.go
@@ -129,7 +129,7 @@ func NewPipeline(actions []*pipeline.ActionPluginStaticInfo, pipelineOpts ...str
 		pName += strconv.Itoa(rand.Int())
 	}
 
-	p := pipeline.New(pName, settings, prometheus.NewRegistry(), zap.NewNop().Sugar())
+	p := pipeline.New(pName, settings, prometheus.NewRegistry(), zap.NewNop())
 	if !parallel {
 		p.DisableParallelism()
 	}