Use profile instead of loading file

Author: qmonmert

generators/spring-cloud/generators/kafka/templates/src/test/java/_package_/config/KafkaTestContainersSpringContextCustomizerFactory.java.ejs

@@ -21,13 +21,8 @@ package <%= packageName %>.config;
 import java.util.List;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
-import org.springframework.boot.test.util.TestPropertyValues;
 import org.springframework.context.ConfigurableApplicationContext;
 import org.springframework.core.annotation.AnnotatedElementUtils;
-import org.springframework.core.env.PropertySource;
-import org.springframework.core.io.ClassPathResource;
-import org.springframework.boot.env.YamlPropertySourceLoader;
 import org.springframework.test.context.ContextConfigurationAttributes;
 import org.springframework.test.context.ContextCustomizer;
 import org.springframework.test.context.ContextCustomizerFactory;
@@ -47,16 +42,7 @@ public class KafkaTestContainersSpringContextCustomizerFactory implements Contex
                 EmbeddedKafka kafkaAnnotation = AnnotatedElementUtils.findMergedAnnotation(testClass, EmbeddedKafka.class);
                 if (null != kafkaAnnotation) {
                     log.debug("detected the EmbeddedKafka annotation on class {}", testClass.getName());
-                    try {
-                        YamlPropertySourceLoader loader = new YamlPropertySourceLoader();
-                        List<PropertySource<?>> sources = loader.load("application-kafka", new ClassPathResource("config/application-kafka.yml"));
-                        for (PropertySource<?> source : sources) {
-                            context.getEnvironment().getPropertySources().addFirst(source);
-                        }
-                    } catch (Exception e) {
-                        log.error("Failed to load application-kafka.yml", e);
-                        throw new RuntimeException(e);
-                    }
+                    context.getEnvironment().addActiveProfile("kafka");
                 }
             }