@Override
        public void operationComplete(ChannelFuture channelFuture) throws Exception {
            if (!channelFuture.isSuccess()) {
                Throwable throwable = channelFuture.cause();
                String clientIp = AddressUtils.getChannelRemoteIP(channelFuture.channel());
                if (logCounter.shouldPrint()) {
                    logger.error("Http return response to client {} failed, exception:{}, errmsg:{}",
                            clientIp, throwable, throwable.getLocalizedMessage());
                }
                channelFuture.channel().close();
            }
            if (isClose) {
                channelFuture.channel().close();
            }
        }
Get attributes from decoder

@param decoder the decode object
@param reqAttrs the attributes
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/httpMsg/HttpMessageHandler.java