public void setAttrInfo(int intMsgType, boolean isCompress, byte[] aesKey, Map<String, String> tgtAttrs) {
        this.intMsgType = intMsgType;
        this.compress = isCompress;
        this.aesKey = aesKey;
        if (tgtAttrs != null && !tgtAttrs.isEmpty()) {
            for (Map.Entry<String, String> entry : tgtAttrs.entrySet()) {
                if (entry == null || StringUtils.isBlank(entry.getKey()) || entry.getValue() == null) {
                    continue;
                }
                this.attrMap.put(entry.getKey().trim(), entry.getValue().trim());
            }
            String preAttrStr = mapJoiner.join(this.attrMap);
            this.attrData = preAttrStr.getBytes(StandardCharsets.UTF_8);
            this.attrDataLength = this.attrData.length;
        }
    }
Encode Object class

Used to encapsulate the reported event information to be sent
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/tcp/codec/EncodeObject.java