使用 JsonNode 修剪有效负载并获取 IntNode 无法转换为类 com.fasterxml.jackson.databind.node.ObjectNode 异常

如何解决使用 JsonNode 修剪有效负载并获取 IntNode 无法转换为类 com.fasterxml.jackson.databind.node.ObjectNode 异常

我有一个简单的问题，我知道你可以帮我解决。我正在使用一个巨大的 String 有效负载，我想为我的 kafka 消费者修剪它。我编写了一个类来处理数据并删除某些数据属性。其中一些是 IntNode、TextNode 和 ArrayNode 类型。我目前正在尝试将所有内容转换为 ObjectNode 并使用 remove(fieldName) 方法，但是我在堆栈跟踪中遇到异常“java.lang.ClassCastException: class com.fasterxml.jackson.databind.node.IntNode cannot be cast to类 com.fasterxml.jackson.databind.node.ObjectNode（com.fasterxml.jackson.databind.node.IntNode 和 com.fasterxml.jackson.databind.node.ObjectNode 位于加载程序“app”的未命名模块中）”

查找附加的我的代码和示例负载。感谢您的时间（我正在尝试删除属性：IntNode 类型的 location_group_id、关系、里程碑、geographic_specifications、联系信息）

package com.target.locationsync.consumer;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.node.ObjectNode;
import com.target.locationsync.models.LocationSync;
import com.target.locationsync.services.ElasticSearchService;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.support.Acknowledgment;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;


import java.util.*;

@Component
public class KafkaConsumerClean{

    public static final Logger logger = LoggerFactory.getLogger(KafkaConsumer.class);
    public static final String JSON_ELEMENT = "locations";

    private final ObjectMapper objectMapper = new ObjectMapper();

    @Autowired
    ElasticSearchService elasticSearchService;

    @Value("${processKafkaMessage}")
    private Boolean processKafkaMessage;

     @KafkaListener(
            topics = "${kafka.topic}",errorHandler = "kafkaErrorHandler",containerFactory = "kafkaListenerContainerFactory",groupId = "${kafka.consumer.group.id}")
    public void receiveLocationData(ConsumerRecord<?,?> consumerRecord,Acknowledgment acknowledgment) throws JsonProcessingException {
        if(processKafkaMessage)
        {
            //String payload =  consumerRecord.value().toString();
            String payload = "{\"location_id\":9117,\"type_code\":\"NY\",\"type_description\":\"Distribution Center\",\"sub_type_code\":\"TFC\",\"status\":\"Open\",\"location_group_id\":7505,\"location_names\":[{\"name_type\":\"Proj Name1\",\"name\":\"Target.com T3857 M1FC\"}],\"address\":[{\"address_context_code\":\"M\",\"address_context_description\":\"Mailing\",\"intersection_description\":null,\"quadrant_code\":null,\"quadrant_description\":null,\"lot_and_block_text\":null,\"address_line1\":\"300 Creekview Ave,Bldg H\",\"address_line2\":null,\"address_line3\":null,\"city\":\"Logan Township\",\"region\":\"NJ\",\"state\":\"New Jersey\",\"postal_code\":\"08014\",\"county\":\"Gloucester\",\"country_code\":\"US\",\"country\":\"United States of America\"},{\"address_context_code\":\"S\",\"address_context_description\":\"Shipping\",\"address_line1\":\"350 Creekview Ave\",\"address_line2\":\"Bldg H\",\"country\":\"United States of America\"}],\"capabilities\":[null],\"physical_specifications\":{\"total_building_area\":null,\"merchandise_level\":null,\"building_level\":null,\"prototype_code\":null,\"format\":null},\"contact_information\":[],\"geographic_specifications\":{\"latitude\":39.78992,\"longitude\":-75.34374,\"time_zone_code\":\"EST\",\"time_zone_description\":\"Eastern Std Time\"},\"milestones\":[{\"milestone_code\":\"Const Turnover\",\"milestone_date\":\"2021-04-08\"},{\"milestone_code\":\"Open Date\",\"milestone_date\":\"2021-06-22\"},{\"milestone_code\":\"Grand Open Date\",\"milestone_date\":\"2021-06-22\"}],\"remodel\":{\"last_remodel_type\":null,\"last_remodel_date\":null},\"miscellaneous\":{\"location_comment\":null,\"research_and_planning_market_name\":\"New York-Northern New Jersey-Long Island\",\"market_id\":35620,\"market_type\":\"Metro\",\"market_state\":\"NY\",\"is_rebuild\":false,\"site_type_code\":null,\"site_type_description\":null,\"sales_volume_code\":null,\"sales_volume_description\":null},\"relationship\":{\"offsite_warehouse\":null,\"sister_store\":null},\"region_group_district\":[null]}";
            

            if(StringUtils.isEmpty(payload)){
                acknowledgment.acknowledge();
            }else{
                try{
                    logger.info("About to process the payload" + payload);
                    String formattedPayload = processLocationData(payload);
                    logger.info("Processed payload: " + formattedPayload);
                    logger.info("Kafka Consumer received data at " + new Date() + " with this payload: " + formattedPayload);
                    acknowledgment.acknowledge();
                }catch(Exception ex){
                    String message = "Error occurred while running kafka listener: " + ex.getMessage();
                    logger.error(new Date() + message);
                    acknowledgment.acknowledge();
                }
            }
        }else{
            acknowledgment.acknowledge();
        }
    }

    private String processLocationData(String payload) throws JsonProcessingException {
        while(payload != null && !payload.isEmpty()){
            JsonNode locationKafkaMessage =  objectMapper.readTree(payload);
            Iterator<JsonNode> jsonNodeIterator = locationKafkaMessage.iterator();
            while(jsonNodeIterator.hasNext()){
                JsonNode locationMessage = jsonNodeIterator.next();//jsonNodeIterator.next is of location_id of type IntNode
           
                ObjectNode kafkaPayload = (ObjectNode) locationMessage;//Problem here
                kafkaPayload.remove("relationship");
                kafkaPayload.remove("milestones");
                kafkaPayload.remove("location_group_id");
                kafkaPayload.remove("geographic_specifications");
                kafkaPayload.remove("contact_information");
                ObjectNode messageJson = objectMapper.createObjectNode();
                try {
                    messageJson.set("locations",objectMapper.valueToTree(kafkaPayload));
                    logger.info("kafka msg" + objectMapper.writeValueAsString(messageJson));
                    logger.info("About to view message Json after trimming");
                    return messageJson.toString();
                } catch (Exception ex) {
                    logger.error("Failed to parse item data for kafka message generation",ex);
                }
                LocationSync locationSync = objectMapper.readValue(messageJson.toString(),LocationSync.class);
                elasticSearchService.updateIndexForLocationSync(locationSync);
            }
        }
        return "No payload to format";
    }
    
    //"{\"location_id\":503,\"type_code\":\"OFFICE\",\"type_description\":\"Office Space\",// \"sub_type_code\":\"BANK\",// \"status\":\"Open\",\"location_group_id\":484,// \"location_names\":[{\"name_type\":\"Proj Name1\",\"name\":\"Target  Sioux Falls\"},// {\"name_type\":\"WorkdayNm\",\"name\":\"HQ Target National Bank\"}],// \"address\":[{\"address_context_code\":\"M\",// \"address_context_description\":\"Mailing\",// \"quadrant_description\":null,\"address_line1\":\"3901 W 53rd St\",// \"address_line2\":null,\"city\":\"Sioux Falls\",\"region\":\"SD\",// \"state\":\"South Dakota\",\"postal_code\":\"57106-4221\",\"county\":\"Minnehaha\",// \"country\":\"United States of America\"}],// \"capabilities\":[null],// \"physical_specifications\":{\"total_building_area\":null,// \"contact_information\":[{\"building_area\":\"MAIN\",\"capability\":null,\"telephone_type\":\"VOICE\",\"is_international_phone_number\":false,\"telephone_number\":\"605-323-2000\",\"extension\":null}],// \"geographic_specifications\":{\"latitude\":43.503773,\"longitude\":-96.771912,\"time_zone_code\":\"CST\",\"time_zone_description\":\"Central Std Time\"},// \"milestones\":[{\"milestone_code\":\"Open Date\",\"milestone_date\":\"1994-11-01\"}],// \"remodel\":{\"last_remodel_type\":null,// \"miscellaneous\":{\"location_comment\":\"Limited Purpose Credit Card Bank that issues Target Visa Credit Card\",\"research_and_planning_market_name\":\"Sioux Falls\",\"market_id\":43620,\"market_state\":\"SD\",// \"relationship\":{\"offsite_warehouse\":null,\"region_group_district\":[null]}";

}