public void initialize()

in ddm-notification-service/src/it/java/com/epam/digital/data/platform/notification/config/KafkaContextInitializer.java [28:36]


  public void initialize(ConfigurableApplicationContext applicationContext) {
    var activeProfiles = applicationContext.getEnvironment().getActiveProfiles();
    var enableKafka = Arrays.asList(activeProfiles).contains("kafka-test");
    if (enableKafka) {
      TestPropertyValues
          .of("data-platform.kafka.enabled=true")
          .applyTo(applicationContext);
    }
  }