Skip to content

Commit deae1b7

Browse files
authored
fix(rest): parse resp skip compression (#3511)
Signed-off-by: Jiyong Huang <huangjy@emqx.io>
1 parent a796124 commit deae1b7

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

internal/io/http/rest_sink.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
// Copyright 2024 EMQ Technologies Co., Ltd.
1+
// Copyright 2024-2025 EMQ Technologies Co., Ltd.
22
//
33
// Licensed under the Apache License, Version 2.0 (the "License");
44
// you may not use this file except in compliance with the License.
@@ -146,7 +146,7 @@ func (r *RestSink) Collect(ctx api.StreamContext, item api.RawTuple) error {
146146
method, u)
147147
} else {
148148
logger.Debugf("rest sink got response %v", resp)
149-
_, b, err := r.parseResponse(ctx, resp, "", r.config.DebugResp, false)
149+
_, b, err := r.parseResponse(ctx, resp, "", r.config.DebugResp, true)
150150
// do not record response body error as it is not an error in the sink action.
151151
if err != nil && !strings.HasPrefix(err.Error(), BODY_ERR) {
152152
if strings.HasPrefix(err.Error(), BODY_ERR) {

0 commit comments

Comments
 (0)