@Override
    public boolean sendMessageWithoutAck(TcpEventInfo eventInfo, ProcessResult procResult) {
        validParamsNotNull(eventInfo, procResult);
        if (!this.isStarted()) {
            return procResult.setFailResult(ErrorCode.SDK_CLOSED);
        }
        long curTime = System.currentTimeMillis();
        try {
            return processEvent(SendQos.NO_ACK, eventInfo, null, procResult);
        } finally {
            if (procResult.isSuccess()) {
                metricHolder.addSyncSucMetric(eventInfo.getGroupId(), eventInfo.getStreamId(),
                        eventInfo.getMsgCnt(), (System.currentTimeMillis() - curTime));
            } else {
                metricHolder.addSyncFailMetric(procResult.getErrCode(),
                        eventInfo.getGroupId(), eventInfo.getStreamId(), eventInfo.getMsgCnt());
            }
        }
    }
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