Skip to content

Commit

Permalink
fix: use test logger
Browse files Browse the repository at this point in the history
  • Loading branch information
Vihas Splunk committed Aug 8, 2023
1 parent 019d5dc commit 2c283ee
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions receiver/kafkareceiver/header_extraction_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ import (
"go.opentelemetry.io/collector/pdata/pmetric"
"go.opentelemetry.io/collector/pdata/ptrace"
"go.opentelemetry.io/collector/receiver/receivertest"
"go.uber.org/zap"
"go.uber.org/zap/zaptest"

"github.com/open-telemetry/opentelemetry-collector-contrib/internal/coreinternal/testdata"
)
Expand All @@ -24,14 +24,14 @@ func TestHeaderExtractionTraces(t *testing.T) {
nextConsumer := &consumertest.TracesSink{}
c := tracesConsumerGroupHandler{
unmarshaler: newPdataTracesUnmarshaler(&ptrace.ProtoUnmarshaler{}, defaultEncoding),
logger: zap.NewNop(),
logger: zaptest.NewLogger(t),
ready: make(chan bool),
nextConsumer: nextConsumer,
obsrecv: obsrecv,
}
headers := []string{"headerKey1", "headerKey2"}
c.headerExtractor = &headerExtractor{
logger: zap.NewNop(),
logger: zaptest.NewLogger(t),
headers: headers,
}
groupClaim := &testConsumerGroupClaim{
Expand Down Expand Up @@ -85,14 +85,14 @@ func TestHeaderExtractionLogs(t *testing.T) {
unmarshaler, err = unmarshaler.WithEnc("utf-8")
c := logsConsumerGroupHandler{
unmarshaler: unmarshaler,
logger: zap.NewNop(),
logger: zaptest.NewLogger(t),
ready: make(chan bool),
nextConsumer: nextConsumer,
obsrecv: obsrecv,
}
headers := []string{"headerKey1", "headerKey2"}
c.headerExtractor = &headerExtractor{
logger: zap.NewNop(),
logger: zaptest.NewLogger(t),
headers: headers,
}
groupClaim := &testConsumerGroupClaim{
Expand Down Expand Up @@ -139,14 +139,14 @@ func TestHeaderExtractionMetrics(t *testing.T) {
nextConsumer := &consumertest.MetricsSink{}
c := metricsConsumerGroupHandler{
unmarshaler: newPdataMetricsUnmarshaler(&pmetric.ProtoUnmarshaler{}, defaultEncoding),
logger: zap.NewNop(),
logger: zaptest.NewLogger(t),
ready: make(chan bool),
nextConsumer: nextConsumer,
obsrecv: obsrecv,
}
headers := []string{"headerKey1", "headerKey2"}
c.headerExtractor = &headerExtractor{
logger: zap.NewNop(),
logger: zaptest.NewLogger(t),
headers: headers,
}
groupClaim := &testConsumerGroupClaim{
Expand Down

0 comments on commit 2c283ee

Please sign in to comment.