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 与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…