public KafkaPrincipal deserialize()

in src/main/java/com/epam/eco/commons/kafka/serde/jackson/KafkaPrincipalJsonDeserializer.java [39:64]

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

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

        String principalType = null;
        String name = null;
        while (fieldName != null) {
            if (KafkaPrincipalFields.PRINCIPAL_TYPE.equals(fieldName)) {
                jsonParser.nextToken();
                principalType = _parseString(jsonParser, ctxt);
            } else if (KafkaPrincipalFields.NAME.equals(fieldName)) {
                jsonParser.nextToken();
                name = _parseString(jsonParser, ctxt);
            } else {
                handleUnknownProperty(jsonParser, ctxt, _valueClass, fieldName);
            }
            fieldName = jsonParser.nextFieldName();
        }

        com.epam.eco.commons.json.JsonDeserializerUtils.assertNotNullValue(principalType, KafkaPrincipalFields.PRINCIPAL_TYPE, _valueClass, ctxt);
        com.epam.eco.commons.json.JsonDeserializerUtils.assertNotNullValue(name, KafkaPrincipalFields.NAME, _valueClass, ctxt);

        return new KafkaPrincipal(principalType, name);
    }