@Override
    public int getInflightMsgCnt() {
        return tcpClientMgr.getInflightMsgCnt();
    }
TCP Message Sender class

Used to define the TCP sender common methods
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/sender/tcp/InLongTcpMsgSender.java