From 8a90c87e52804501ea7d6a621c070b175185f585 Mon Sep 17 00:00:00 2001 From: Dmitrii Anoshin Date: Sun, 2 Feb 2025 15:13:56 -0800 Subject: [PATCH] [chore] Simplify condition in NewBaseExporter --- exporter/exporterhelper/internal/base_exporter.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/exporter/exporterhelper/internal/base_exporter.go b/exporter/exporterhelper/internal/base_exporter.go index a2b2991361b..4bae09032c2 100644 --- a/exporter/exporterhelper/internal/base_exporter.go +++ b/exporter/exporterhelper/internal/base_exporter.go @@ -100,8 +100,7 @@ func NewBaseExporter(set exporter.Settings, signal pipeline.Signal, osf ObsrepSe be.ConsumerOptions = append(be.ConsumerOptions, consumer.WithCapabilities(consumer.Capabilities{MutatesData: true})) } - if !usePullingBasedExporterQueueBatcher.IsEnabled() && be.batcherCfg.Enabled || - usePullingBasedExporterQueueBatcher.IsEnabled() && be.batcherCfg.Enabled && !be.queueCfg.Enabled { + if be.batcherCfg.Enabled && !(usePullingBasedExporterQueueBatcher.IsEnabled() && be.queueCfg.Enabled) { concurrencyLimit := int64(0) if be.queueCfg.Enabled { concurrencyLimit = int64(be.queueCfg.NumConsumers)