public RecordHeader deserialize()

in src/main/java/com/epam/eco/commons/kafka/serde/jackson/RecordHeaderJsonDeserializer.java [43:67]

• 22 lines of code
• 5 McCabe index (conditional complexity)

    public RecordHeader deserialize(JsonParser jsonParser, DeserializationContext ctxt) throws IOException {
        if (jsonParser.getCurrentToken() == JsonToken.START_OBJECT) {
            jsonParser.nextToken();
        }
        String fieldName = jsonParser.getCurrentName();

        String key = null;
        byte[] value = null;
        while (fieldName != null) {
            if (RecordHeaderFields.KEY.equals(fieldName)) {
                jsonParser.nextToken();
                key = _parseString(jsonParser, ctxt);
            } else if (RecordHeaderFields.VALUE.equals(fieldName)) {
                jsonParser.nextToken();
                value = jsonParser.getBinaryValue();
            } else {
                handleUnknownProperty(jsonParser, ctxt, _valueClass, fieldName);
            }
            fieldName = jsonParser.nextFieldName();
        }

        com.epam.eco.commons.json.JsonDeserializerUtils.assertNotNullValue(key, RecordHeaderFields.KEY, _valueClass, ctxt);

        return new RecordHeader(key, value);
    }