spring - using KafkaTemplate and ReplyingKafkaTemplate together

Question

I want to use same topic for both synchronous and asynchronus communication.

For Synchronous communication, I want to use ReplyingKafkaTemplate and for asynchronous communication i will use KafKaTemplate in the same gateway.

For Synchronous communication :

  ProducerRecord<String, RequestModel> record = new ProducerRecord<String, Model>(requestTopic, request);
        // set reply topic in header
        record.headers().add(new RecordHeader(KafkaHeaders.REPLY_TOPIC, requestReplyTopic.getBytes()));
        // post in kafka topic
        RequestReplyFuture<String, RequestModel, Model> sendAndReceive = replyingKafkaTemplate.sendAndReceive(record);
  
        // get consumer record
        ConsumerRecord<String, ResponseModel> consumerRecord = sendAndReceive.get();
        // return consumer value
        return consumerRecord.value();

For asynchronous communication :

kafkaTemplate.send(model);

Asynchoronus listener :

   @KafkaListener(topics = KafkaConfiguration.Topic)
    public void replyChatMessage(@Payload Model model) {

        .....
    }

But ReplyingKafkaTemplate is overriding KafkaTemplate. In the asynchronous listener, i am getting correlationId missising exception.

Is there a way to use these two structures in the same gateway. I tried to change listeners but it didn't help.

question from:https://stackoverflow.com/questions/65944353/using-kafkatemplate-and-replyingkafkatemplate-together

Answer 1

Waitting for answers