Deactivation Kafka auto-configuration

Author: qmonmert

generators/spring-boot/templates/src/test/resources/config/application.yml.ejs

@@ -63,10 +63,15 @@ mongock:
 spring:
   application:
     name: <%= baseName %>
-<%_ if (applicationTypeGateway) { _%>
+<%_ if (applicationTypeGateway || messageBrokerKafka) { _%>
   autoconfigure:
     exclude:
+  <%_ if (applicationTypeGateway) { _%>
       - org.springframework.cloud.gateway.config.GatewayMetricsAutoConfiguration
+  <%_ } _%>
+  <%_ if (messageBrokerKafka) { _%>
+      - org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration
+  <%_ } _%>
 <%_ } _%>
 <%_ if (serviceDiscoveryEureka || serviceDiscoveryConsul || messageBrokerAny) { _%>
   cloud:
@@ -86,24 +91,11 @@ spring:
 <%_ } _%>
 <%_ if (messageBrokerKafka) { _%>
     function:
-      definition: kafkaConsumer;kafkaProducer
+      scan:
+        enabled: false
+      definition: ''
     stream:
-      enabled: false
-      kafka:
-        binder:
-          replicationFactor: 1
-          auto-create-topics: true
-      bindings:
-        binding-out-0:
-          content-type: text/plain
-          group: <%= dasherizedBaseName %>
-        kafkaConsumer-in-0:
-          destination: sse-topic
-          content-type: text/plain
-          group: <%= dasherizedBaseName %>
-        kafkaProducer-out-0:
-          content-type: text/plain
-          group: <%= dasherizedBaseName %>
+      defaultBinder: test
 <%_ } _%>
 <%_ if (messageBrokerPulsar) { _%>
     function:
@@ -230,3 +222,7 @@ management:
   health:
     mail:
       enabled: false
+<%_ if (messageBrokerKafka) { _%>
+    kafka:
+      enabled: false
+<%_ } _%>

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

@@ -34,34 +34,33 @@ public class KafkaTestContainersSpringContextCustomizerFactory implements Contex
 
     private Logger log = LoggerFactory.getLogger(KafkaTestContainersSpringContextCustomizerFactory.class);
 
-    private static KafkaTestContainer kafkaBean;
-
     @Override
     public ContextCustomizer createContextCustomizer(Class<?> testClass, List<ContextConfigurationAttributes> configAttributes) {
 
         return new ContextCustomizer() {
             @Override
             public void customizeContext(ConfigurableApplicationContext context,
                     MergedContextConfiguration mergedConfig) {
-                ConfigurableListableBeanFactory beanFactory = context.getBeanFactory();
                 TestPropertyValues testValues = TestPropertyValues.empty();
                 EmbeddedKafka kafkaAnnotation = AnnotatedElementUtils.findMergedAnnotation(testClass, EmbeddedKafka.class);
                 if (null != kafkaAnnotation) {
                     log.debug("detected the EmbeddedKafka annotation on class {}", testClass.getName());
-                    log.info("Warming up the kafka broker");
-                    if (null == kafkaBean) {
-                        kafkaBean = beanFactory.createBean(KafkaTestContainer.class);
-                        beanFactory.registerSingleton(KafkaTestContainer.class.getName(), kafkaBean);
-                    }
-                    testValues = testValues.and("spring.cloud.stream.kafka.binder.brokers=" + kafkaBean.getKafkaContainer().getHost() + ':' + kafkaBean.getKafkaContainer().getFirstMappedPort());
-                    testValues = testValues.and("spring.cloud.stream.enabled=true");
+                    testValues = testValues.and("spring.cloud.function.scan.enabled=true");
+                    testValues = testValues.and("spring.cloud.function.definition=kafkaConsumer;kafkaProducer");
+                    testValues = testValues.and("spring.cloud.stream.bindings.binding-out-0.content-type=text/plain");
+                    testValues = testValues.and("spring.cloud.stream.bindings.binding-out-0.group=<%= dasherizedBaseName %>");
+                    testValues = testValues.and("spring.cloud.stream.bindings.kafkaConsumer-in-0.destination=sse-topic");
+                    testValues = testValues.and("spring.cloud.stream.bindings.kafkaConsumer-in-0.content-type=text/plain");
+                    testValues = testValues.and("spring.cloud.stream.bindings.kafkaConsumer-in-0.group=<%= dasherizedBaseName %>");
+                    testValues = testValues.and("spring.cloud.stream.bindings.kafkaProducer-out-0.content-type=text/plain");
+                    testValues = testValues.and("spring.cloud.stream.bindings.kafkaProducer-out-0.group=<%= dasherizedBaseName %>");
                 }
                 testValues.applyTo(context);
             }
 
             @Override
             public int hashCode() {
-                return KafkaTestContainer.class.getName().hashCode();
+                return KafkaTestContainersSpringContextCustomizerFactory.class.getName().hashCode();
             }
 
             @Override