Skip to content

Commit d2e0ded

Browse files
committed
fix(rest): parse resp skip compression (lf-edge#3511)
Signed-off-by: Jiyong Huang <huangjy@emqx.io>
1 parent ececef2 commit d2e0ded

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

internal/io/http/rest_sink.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,7 @@ func (r *RestSink) Collect(ctx api.StreamContext, item api.RawTuple) error {
138138
method, u)
139139
} else {
140140
logger.Debugf("rest sink got response %v", resp)
141-
_, b, err := r.parseResponse(ctx, resp, "", r.config.DebugResp, false)
141+
_, b, err := r.parseResponse(ctx, resp, "", r.config.DebugResp, true)
142142
// do not record response body error as it is not an error in the sink action.
143143
if err != nil && !strings.HasPrefix(err.Error(), BODY_ERR) {
144144
if strings.HasPrefix(err.Error(), BODY_ERR) {

0 commit comments

Comments
 (0)