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);
}
}