Мобильная версияУ меня есть 2 темы на стороне потребителя Kafka. Тема А и тема Б. Оба собираются одним и тем же методом. Подробности метода приведены ниже;
@Slf4j @Услуга общественный класс KafkaConsumerService { @KafkaListener(topics = { "topic-a", "topic-b" }, groupId = "X-consumer") public void ListenX(Response msg) { log.info("MSG доставлен потребителю"); KafkaMessageDTO test = msg.getData(); @Data @AllArgsConstructor @NoArgsConstructor @Builder общественный класс KafkaMessageDTO { @JsonProperty("объект") частный объект Т; @JsonProperty("заголовок") частные заголовки HttpHeaders; } Я всегда отправляю этому методу тип переменной msg — KafkaMessageDTO. Пытаюсь извлечь объект из KafkaMessageDTO (kafkaMessageDTO.getObject()), но, к сожалению, не могу этого сделать.
При отладке я вижу значения и похоже, что данные идеально совпадают, как показано ниже.
Как преобразовать объект msg в объект KafkaMessageDTO? Пока я пытаюсь преобразовать это, я получаю эту ошибку
выдал исключение; вложенным исключением является java.lang.ClassCastException: класс java.util.LinkedHashMap не может быть приведен к классу com.token.dto.TokenMobieDTO (java.util.LinkedHashMap находится в модуле java.base загрузчика 'bootstrap'; Я пытался сопоставить, но поскольку данные не содержат список, я не могу выполнять итерацию.