public void decInFlightMsgCnt(long termId) {
        if (this.channelTermId.get() != termId) {
            return;
        }
        this.msgInflightCnt.decrementAndGet();
    }
TCP Netty client class

Used to manage TCP netty client, including connection, closing, keep-alive, sending status check, etc.
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/tcp/TcpNettyClient.java