diff --git a/backend/src/main/java/ervu_business_metrics/dao/AccountDataDao.java b/backend/src/main/java/ervu_business_metrics/dao/AccountDataDao.java
index d25979b..c2c38e2 100644
--- a/backend/src/main/java/ervu_business_metrics/dao/AccountDataDao.java
+++ b/backend/src/main/java/ervu_business_metrics/dao/AccountDataDao.java
@@ -2,8 +2,10 @@ package ervu_business_metrics.dao;
 
 import java.util.List;
 
+import ervu_business_metrics.config.KafkaEnabledCondition;
 import org.jooq.DSLContext;
 import org.jooq.Table;
+import org.springframework.context.annotation.Conditional;
 import org.springframework.stereotype.Repository;
 import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.Tables;
 import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.AccountRecord;
@@ -13,6 +15,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
  * @author Adel Kalimullin
  */
 @Repository
+@Conditional(KafkaEnabledCondition.class)
 public class AccountDataDao extends AbstractDataDao<AccountRecord> {
 
   protected AccountDataDao(DSLContext dsl) {
diff --git a/backend/src/main/java/ervu_business_metrics/dao/AccountRoleDataDao.java b/backend/src/main/java/ervu_business_metrics/dao/AccountRoleDataDao.java
index 4e024a5..dda55f9 100644
--- a/backend/src/main/java/ervu_business_metrics/dao/AccountRoleDataDao.java
+++ b/backend/src/main/java/ervu_business_metrics/dao/AccountRoleDataDao.java
@@ -4,9 +4,11 @@ package ervu_business_metrics.dao;
 import java.util.List;
 import java.util.Map;
 
+import ervu_business_metrics.config.KafkaEnabledCondition;
 import org.jooq.DSLContext;
 import org.jooq.Field;
 import org.jooq.Table;
+import org.springframework.context.annotation.Conditional;
 import org.springframework.stereotype.Repository;
 import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.Tables;
 import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.AccountRoleRecord;
@@ -16,6 +18,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
  * @author Adel Kalimullin
  */
 @Repository
+@Conditional(KafkaEnabledCondition.class)
 public class AccountRoleDataDao extends AbstractDataDao<AccountRoleRecord> {
 
   protected AccountRoleDataDao(DSLContext dsl) {
diff --git a/backend/src/main/java/ervu_business_metrics/dao/DomainDataDao.java b/backend/src/main/java/ervu_business_metrics/dao/DomainDataDao.java
index 17ba304..5753e66 100644
--- a/backend/src/main/java/ervu_business_metrics/dao/DomainDataDao.java
+++ b/backend/src/main/java/ervu_business_metrics/dao/DomainDataDao.java
@@ -1,8 +1,10 @@
 package ervu_business_metrics.dao;
 
 
+import ervu_business_metrics.config.KafkaEnabledCondition;
 import org.jooq.DSLContext;
 import org.jooq.Table;
+import org.springframework.context.annotation.Conditional;
 import org.springframework.stereotype.Repository;
 import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.Tables;
 import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.DomainRecord;
@@ -11,6 +13,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
  * @author Adel Kalimullin
  */
 @Repository
+@Conditional(KafkaEnabledCondition.class)
 public class DomainDataDao extends AbstractDataDao<DomainRecord> {
 
   protected DomainDataDao(DSLContext dsl) {
diff --git a/backend/src/main/java/ervu_business_metrics/dao/PersonDataDao.java b/backend/src/main/java/ervu_business_metrics/dao/PersonDataDao.java
index 8f2e759..174b56a 100644
--- a/backend/src/main/java/ervu_business_metrics/dao/PersonDataDao.java
+++ b/backend/src/main/java/ervu_business_metrics/dao/PersonDataDao.java
@@ -1,7 +1,9 @@
 package ervu_business_metrics.dao;
 
+import ervu_business_metrics.config.KafkaEnabledCondition;
 import org.jooq.DSLContext;
 import org.jooq.Table;
+import org.springframework.context.annotation.Conditional;
 import org.springframework.stereotype.Repository;
 import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.Tables;
 import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.PersonRecord;
@@ -10,6 +12,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
  * @author Adel Kalimullin
  */
 @Repository
+@Conditional(KafkaEnabledCondition.class)
 public class PersonDataDao extends AbstractDataDao<PersonRecord> {
 
   protected PersonDataDao(DSLContext dsl) {
diff --git a/backend/src/main/java/ervu_business_metrics/dao/RoleDataDao.java b/backend/src/main/java/ervu_business_metrics/dao/RoleDataDao.java
index db79165..b18e4d9 100644
--- a/backend/src/main/java/ervu_business_metrics/dao/RoleDataDao.java
+++ b/backend/src/main/java/ervu_business_metrics/dao/RoleDataDao.java
@@ -1,7 +1,9 @@
 package ervu_business_metrics.dao;
 
+import ervu_business_metrics.config.KafkaEnabledCondition;
 import org.jooq.DSLContext;
 import org.jooq.Table;
+import org.springframework.context.annotation.Conditional;
 import org.springframework.stereotype.Repository;
 import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.Tables;
 import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.RoleRecord;
@@ -10,6 +12,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
  * @author Adel Kalimullin
  */
 @Repository
+@Conditional(KafkaEnabledCondition.class)
 public class RoleDataDao extends AbstractDataDao<RoleRecord> {
 
   protected RoleDataDao(DSLContext dsl) {
diff --git a/backend/src/main/java/ervu_business_metrics/service/processor/impl/AccountDataProcessor.java b/backend/src/main/java/ervu_business_metrics/service/processor/impl/AccountDataProcessor.java
index 2336c55..b0515e2 100644
--- a/backend/src/main/java/ervu_business_metrics/service/processor/impl/AccountDataProcessor.java
+++ b/backend/src/main/java/ervu_business_metrics/service/processor/impl/AccountDataProcessor.java
@@ -5,10 +5,12 @@ import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
 
+import ervu_business_metrics.config.KafkaEnabledCondition;
 import ervu_business_metrics.dao.AccountDataDao;
 import ervu_business_metrics.model.ReferenceEntity;
 import ervu_business_metrics.model.idm.AccountData;
 import ervu_business_metrics.service.processor.DataProcessor;
+import org.springframework.context.annotation.Conditional;
 import org.springframework.stereotype.Component;
 import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.AccountRecord;
 
@@ -17,6 +19,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
  * @author Adel Kalimullin
  */
 @Component
+@Conditional(KafkaEnabledCondition.class)
 public class AccountDataProcessor implements DataProcessor<AccountData, AccountRecord> {
   private final AccountDataDao dao;
   private final AccountRoleDataProcessor accountRoleDataProcessor;
diff --git a/backend/src/main/java/ervu_business_metrics/service/processor/impl/AccountRoleDataProcessor.java b/backend/src/main/java/ervu_business_metrics/service/processor/impl/AccountRoleDataProcessor.java
index 0e95c69..0269ef9 100644
--- a/backend/src/main/java/ervu_business_metrics/service/processor/impl/AccountRoleDataProcessor.java
+++ b/backend/src/main/java/ervu_business_metrics/service/processor/impl/AccountRoleDataProcessor.java
@@ -5,11 +5,13 @@ import java.util.List;
 import java.util.Set;
 import java.util.stream.Collectors;
 
+import ervu_business_metrics.config.KafkaEnabledCondition;
 import ervu_business_metrics.dao.AccountRoleDataDao;
 import ervu_business_metrics.model.idm.AccountData;
 import ervu_business_metrics.model.idm.AccountRoleData;
 import ervu_business_metrics.model.idm.RoleData;
 import ervu_business_metrics.service.processor.LinkDataProcessor;
+import org.springframework.context.annotation.Conditional;
 import org.springframework.stereotype.Component;
 import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.AccountRoleRecord;
 
@@ -17,6 +19,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
  * @author Adel Kalimullin
  */
 @Component
+@Conditional(KafkaEnabledCondition.class)
 public class AccountRoleDataProcessor
     implements LinkDataProcessor<AccountRoleData, AccountRoleRecord> {
   private final AccountRoleDataDao dao;
diff --git a/backend/src/main/java/ervu_business_metrics/service/processor/impl/DomainDataProcessor.java b/backend/src/main/java/ervu_business_metrics/service/processor/impl/DomainDataProcessor.java
index 99e0297..07832b9 100644
--- a/backend/src/main/java/ervu_business_metrics/service/processor/impl/DomainDataProcessor.java
+++ b/backend/src/main/java/ervu_business_metrics/service/processor/impl/DomainDataProcessor.java
@@ -1,8 +1,10 @@
 package ervu_business_metrics.service.processor.impl;
 
+import ervu_business_metrics.config.KafkaEnabledCondition;
 import ervu_business_metrics.dao.DomainDataDao;
 import ervu_business_metrics.model.idm.DomainData;
 import ervu_business_metrics.service.processor.DataProcessor;
+import org.springframework.context.annotation.Conditional;
 import org.springframework.stereotype.Component;
 import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.DomainRecord;
 
@@ -10,6 +12,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
  * @author Adel Kalimullin
  */
 @Component
+@Conditional(KafkaEnabledCondition.class)
 public class DomainDataProcessor implements DataProcessor<DomainData, DomainRecord> {
   private final DomainDataDao dao;
 
diff --git a/backend/src/main/java/ervu_business_metrics/service/processor/impl/PersonDataProcessor.java b/backend/src/main/java/ervu_business_metrics/service/processor/impl/PersonDataProcessor.java
index 9bc945e..304fe04 100644
--- a/backend/src/main/java/ervu_business_metrics/service/processor/impl/PersonDataProcessor.java
+++ b/backend/src/main/java/ervu_business_metrics/service/processor/impl/PersonDataProcessor.java
@@ -1,8 +1,10 @@
 package ervu_business_metrics.service.processor.impl;
 
+import ervu_business_metrics.config.KafkaEnabledCondition;
 import ervu_business_metrics.dao.PersonDataDao;
 import ervu_business_metrics.model.idm.PersonData;
 import ervu_business_metrics.service.processor.DataProcessor;
+import org.springframework.context.annotation.Conditional;
 import org.springframework.stereotype.Component;
 import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.PersonRecord;
 
@@ -10,6 +12,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
  * @author Adel Kalimullin
  */
 @Component
+@Conditional(KafkaEnabledCondition.class)
 public class PersonDataProcessor implements DataProcessor<PersonData, PersonRecord> {
   private final PersonDataDao dao;
   private final AccountDataProcessor accountDataProcessor;
diff --git a/backend/src/main/java/ervu_business_metrics/service/processor/impl/RoleDataProcessor.java b/backend/src/main/java/ervu_business_metrics/service/processor/impl/RoleDataProcessor.java
index ca053bc..381e6c3 100644
--- a/backend/src/main/java/ervu_business_metrics/service/processor/impl/RoleDataProcessor.java
+++ b/backend/src/main/java/ervu_business_metrics/service/processor/impl/RoleDataProcessor.java
@@ -1,9 +1,11 @@
 package ervu_business_metrics.service.processor.impl;
 
 
+import ervu_business_metrics.config.KafkaEnabledCondition;
 import ervu_business_metrics.dao.RoleDataDao;
 import ervu_business_metrics.model.idm.RoleData;
 import ervu_business_metrics.service.processor.DataProcessor;
+import org.springframework.context.annotation.Conditional;
 import org.springframework.stereotype.Component;
 import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.RoleRecord;
 
@@ -11,6 +13,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
  * @author Adel Kalimullin
  */
 @Component
+@Conditional(KafkaEnabledCondition.class)
 public class RoleDataProcessor implements DataProcessor<RoleData, RoleRecord> {
   private final RoleDataDao dao;