diff --git a/contrib/codecs/http/codec.go b/contrib/codecs/http/codec.go index fa5782326fd26ba75dccdf9f0836b276447b3b07..7e2ca915e07587a772cc2cfe2f22448ccb34a6e2 100644 --- a/contrib/codecs/http/codec.go +++ b/contrib/codecs/http/codec.go @@ -204,7 +204,7 @@ func (c *Codec) ReadBatch(ctx context.Context) ([]*codec.Message, bool, error) { case ans := <-c.msgs: return ans.Messages, ans.Batch, nil case err := <-c.errCh: - // http.Error(c.w, err.err.Error(), err.code) + http.Error(c.w, err.err.Error(), err.code) return nil, false, err.err case <-ctx.Done(): return nil, false, ctx.Err()