Skip to content

Commit c504aa0

Browse files
authored
chore: disable transformer compaction by default (#5766)
# Description disabling transformer request payload compaction ## Security - [x] The code changed/added as part of this pull request won't create any security issues with how the software is being used.
1 parent dbc830f commit c504aa0

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

processor/internal/transformer/destination_transformer/destination_transformer.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ func New(conf *config.Config, log logger.Logger, stat stats.Stats, opts ...Opt)
8282
handle.loggedEventsMu = sync.Mutex{}
8383
handle.loggedFileName = generateLogFileName()
8484

85-
handle.config.compactionEnabled = conf.GetReloadableBoolVar(true, "Processor.DestinationTransformer.compactionEnabled", "Transformer.compactionEnabled")
85+
handle.config.compactionEnabled = conf.GetReloadableBoolVar(false, "Processor.DestinationTransformer.compactionEnabled", "Transformer.compactionEnabled")
8686

8787
for _, opt := range opts {
8888
opt(handle)

router/transformer/transformer.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -600,7 +600,7 @@ func (trans *handle) setup(destinationTimeout, transformTimeout time.Duration, c
600600
trans.proxyClientOAuthV2 = oauthv2httpclient.NewOAuthHttpClient(&http.Client{Transport: trans.tr, Timeout: trans.destinationTimeout + trans.transformTimeout}, common.RudderFlowDelivery, cache, backendConfig, GetAuthErrorCategoryFromTransformProxyResponse, proxyClientOptionalArgs)
601601
trans.stats = stats.Default
602602
trans.transformRequestTimerStat = stats.Default.NewStat("router.transformer_request_time", stats.TimerType)
603-
trans.compactionEnabled = config.GetReloadableBoolVar(true, "Router.DestinationTransformer.compactionEnabled", "Transformer.compactionEnabled")
603+
trans.compactionEnabled = config.GetReloadableBoolVar(false, "Router.DestinationTransformer.compactionEnabled", "Transformer.compactionEnabled")
604604
if featuresService != nil {
605605
go func() {
606606
<-featuresService.Wait()

0 commit comments

Comments
 (0)