Skip to content

Commit 741985b

Browse files
authored
[chore] Mark the new batcher config as mutating as well (#12766)
No changelog needed since it's not released yet
1 parent 68e964a commit 741985b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

exporter/exporterhelper/internal/base_exporter.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ func NewBaseExporter(set exporter.Settings, signal pipeline.Signal, pusher sende
8383
return nil, err
8484
}
8585

86-
if be.batcherCfg.Enabled {
86+
if be.batcherCfg.Enabled || be.queueCfg.Batch != nil {
8787
// Batcher mutates the data.
8888
be.ConsumerOptions = append(be.ConsumerOptions, consumer.WithCapabilities(consumer.Capabilities{MutatesData: true}))
8989
}

0 commit comments

Comments
 (0)