Parse InLongMsg

    Dependency

    • Add Maven Dependency
    • Add Parse Method
    1. public static List<byte[]> parserInLongMsg(byte[] bytes) {
    2.     List<byte[]> originalContentByteList = new ArrayList<>();
    3.     InLongMsg inLongMsg = InLongMsg.parseFrom(bytes);
    4.     Set<String> attrs = inLongMsg.getAttrs();
    5.     if (CollectionUtils.isEmpty(attrs)) {
    6.     }
    7.     for (String attr : attrs) {
    9.             continue;
    10.         }
    11.         Iterator<byte[]> iterator = inLongMsg.getIterator(attr);
    12.         if (iterator == null) {
    13.             continue;
    14.         }
    15.             byte[] bodyBytes = iterator.next();
    17.                 continue;
    18.             }
    19.             // Origin data sended by InLong agent
    20.             originalContentByteList.add(bodyBytes);
    21.         }
    22.     }
    23.     return originalContentByteList;