public static B byte2Object()

in core/src/main/java/org/apache/rocketmq/streams/core/util/Utils.java [97:103]

• 6 lines of code
• 4 McCabe index (conditional complexity)

    public static <B> B byte2Object(byte[] source, Class<B> clazz) throws IOException {
        if (source == null || source.length == 0 || clazz == null) {
            return null;
        }

        return objectMapper.readValue(source, clazz);
    }