Skip to content

Commit 0a753a7

Browse files
authored
[chore][receiver/cloudfoundry]: log error encountered while consuming (open-telemetry#35641)
#### Description Log errors encountered while calling `ConsumeLogs()` and `ConsumeMetrics()`.
1 parent a41298f commit 0a753a7

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

receiver/cloudfoundryreceiver/receiver.go

+7
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@ import (
1818
"go.opentelemetry.io/collector/pdata/pmetric"
1919
"go.opentelemetry.io/collector/receiver"
2020
"go.opentelemetry.io/collector/receiver/receiverhelper"
21+
"go.uber.org/zap"
2122

2223
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/cloudfoundryreceiver/internal/metadata"
2324
)
@@ -179,6 +180,9 @@ func (cfr *cloudFoundryReceiver) streamMetrics(
179180
if libraryMetrics.Len() > 0 {
180181
obsCtx := cfr.obsrecv.StartMetricsOp(ctx)
181182
err := cfr.nextMetrics.ConsumeMetrics(ctx, metrics)
183+
if err != nil {
184+
cfr.settings.Logger.Error("Failed to consume metrics", zap.Error(err))
185+
}
182186
cfr.obsrecv.EndMetricsOp(obsCtx, dataFormat, metrics.DataPointCount(), err)
183187
}
184188
}
@@ -213,6 +217,9 @@ func (cfr *cloudFoundryReceiver) streamLogs(
213217
if libraryLogs.Len() > 0 {
214218
obsCtx := cfr.obsrecv.StartLogsOp(ctx)
215219
err := cfr.nextLogs.ConsumeLogs(ctx, logs)
220+
if err != nil {
221+
cfr.settings.Logger.Error("Failed to consume logs", zap.Error(err))
222+
}
216223
cfr.obsrecv.EndLogsOp(obsCtx, dataFormat, logs.LogRecordCount(), err)
217224
}
218225
}

0 commit comments

Comments
 (0)