micord/ervu-lkrp-ul
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

SUPPORT-8474: Fix

Browse source
This commit is contained in:
Eduard Tihomirov 2024-09-06 16:20:29 +03:00
parent c78954a21c
commit dd2ecba904
2 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
backend/src/main/java/ru/micord/ervu/kafka/ErvuKafkaConfig.java
View file

@ -13,6 +13,7 @@ import org.springframework.kafka.core.*;
import org.springframework.kafka.listener.ConcurrentMessageListenerContainer;
import org.springframework.kafka.requestreply.ReplyingKafkaTemplate;
import java.time.Duration;
import java.util.HashMap;
import java.util.Map;
@ -76,6 +77,7 @@ public class ErvuKafkaConfig {
ReplyingKafkaTemplate<String, String, String> replyingKafkaTemplate =
new ReplyingKafkaTemplate<>(pf, container);
replyingKafkaTemplate.setCorrelationHeaderName("messageID");
replyingKafkaTemplate.setDefaultReplyTimeout(Duration.ofSeconds(1000L));
return replyingKafkaTemplate;
}
}

2
config/patches/default.cli
View file

@ -53,5 +53,5 @@ xa-data-source add \
/system-property=client-cert-hash:add(value="04508B4B0B58776A954A0E15F574B4E58799D74C61EE020B3330716C203E3BDD")
/system-property=ervu-kafka.bootstrap-servers:add(value="localhost:9092")
/system-property=ervu-kafka.reply-topic:add(value="ervu.organization.response")
/system-property=ervu-kafka.group-id:add(value="123123")
/system-property=ervu-kafka.group-id:add(value="1")
/system-property=ervu-kafka.request-topic:add(value="ervu.organization.request")