Десериализация другой полезной нагрузки JSON из той же темы Kafka с помощью Spring Kafka - Syncronous

Question

Привет, я пытаюсь использовать две разные полезные нагрузки json из одной темы, и я использую другую containerFactory.

Это работает для одной полезной нагрузки и не работает для других ниже, мой пример кода может помочь мне в этом.

import request.DocumentContentRequest;
import response.DocumentContentResponse;

@KafkaListener(topics = "${kafka.topic.request}", containerFactory = "documentServiceRequestReplyListenerContainerFactory")


@KafkaListener(topics = "${kafka.topic.ecm.request}", containerFactory = "requestReplyListenerContainerFactory")

public class KafkaConsumer {

LoggerFactory.getLogger(KafkaConsumer.class);
    @KafkaHandler
    @SendTo("${kafka.topic.reply}")
    public PERequest receive(PERequest perequest) {
        System.out.println("Received request::"+perequest.toString());

        return perequest;
    }
    @KafkaHandler
    @SendTo("${kafka.topic.reply}")
    public DocumentContentRequest receive(DocumentContentRequest documentRequest) {
        System.out.println("Received request::"+documentRequest.toString());


        return documentRequest;
    }


}