SUPPORT-8696: Fix
This commit is contained in:
parent
150829052b
commit
e8cb3205be
2 changed files with 4 additions and 2 deletions
|
|
@ -78,7 +78,7 @@ public class ErvuDirectoriesService {
|
|||
|
||||
}
|
||||
|
||||
@KafkaListener(id = "${kafka.consumer_group_id}", topics = "${kafka.domain.reconciliation}")
|
||||
@KafkaListener(id = "${kafka.domain.group.id}", topics = "${kafka.domain.reconciliation}")
|
||||
@Transactional
|
||||
public void listenKafkaDomain(String kafkaMessage) {
|
||||
RecruitmentResponse[] response = null;
|
||||
|
|
@ -96,7 +96,7 @@ public class ErvuDirectoriesService {
|
|||
}
|
||||
}
|
||||
|
||||
@KafkaListener(id = "${kafka.consumer_group_id}", topics = "${kafka.role.reconciliation}")
|
||||
@KafkaListener(id = "${kafka.role.group.id}", topics = "${kafka.role.reconciliation}")
|
||||
@Transactional
|
||||
public void listenKafkaRole(String kafkaMessage) {
|
||||
RoleResponse[] response = null;
|
||||
|
|
|
|||
|
|
@ -19,6 +19,8 @@ KAFKA_AUTH_SASL_MODULE=org.apache.kafka.common.security.scram.ScramLoginModule
|
|||
KAFKA_USER=user1
|
||||
KAFKA_PASS=Blfi9d2OFG
|
||||
KAFKA_CONSUMER_GROUP_ID=1
|
||||
KAFKA_DOMAIN_GROUP_ID=ervu-account-applications-backend-domain
|
||||
KAFKA_ROLE_GROUP_ID=ervu-account-applications-backend-role
|
||||
|
||||
ERVU_URL=https://ervu-dev.pgs.rtlabs.ru
|
||||
ERVU_HTTP_TIMEOUT=30
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue