Merge pull request #2455 from fdelbrayelle/feat/issues/2109_kafka_module

Migrate Kafka domain service to new module system

src/main/java/tech/jhipster/lite/generator/project/domain/GeneratorAction.java

@@ -62,10 +62,6 @@ private GeneratorAction() {}
 
   public static final String REACT_CYPRESS = "react-cypress";
 
-  public static final String SPRINGBOOT_KAFKA = "springboot-kafka";
-  public static final String SPRINGBOOT_KAFKA_DUMMY_PRODUCER_CONSUMER = "springboot-kafka-dummy-producer-consumer";
-  public static final String SPRINGBOOT_KAFKA_AKHQ = "springboot-kafka-akhq";
-
   public static final String SPRINGBOOT_PULSAR = "springboot-pulsar";
 
   public static final String SPRINGBOOT_WEBFLUX_NETTY = "springboot-webflux-netty";

src/main/java/tech/jhipster/lite/generator/server/springboot/banner/infrastructure/primary/rest/BannerResourceConfiguration.java → src/main/java/tech/jhipster/lite/generator/server/springboot/banner/infrastructure/primary/rest/BannerModuleConfiguration.java

@@ -7,7 +7,7 @@
 import tech.jhipster.lite.module.infrastructure.primary.JHipsterModuleResource;
 
 @Configuration
-class BannerResourceConfiguration {
+class BannerModuleConfiguration {
 
   private static final String TAG = "Spring Boot";
 

src/main/java/tech/jhipster/lite/generator/server/springboot/broker/kafka/application/KafkaApplicationService.java

@@ -1,27 +1,29 @@
 package tech.jhipster.lite.generator.server.springboot.broker.kafka.application;
 
 import org.springframework.stereotype.Service;
-import tech.jhipster.lite.generator.project.domain.Project;
-import tech.jhipster.lite.generator.server.springboot.broker.kafka.domain.KafkaService;
+import tech.jhipster.lite.docker.domain.DockerImages;
+import tech.jhipster.lite.generator.server.springboot.broker.kafka.domain.KafkaModuleFactory;
+import tech.jhipster.lite.module.domain.JHipsterModule;
+import tech.jhipster.lite.module.domain.properties.JHipsterModuleProperties;
 
 @Service
 public class KafkaApplicationService {
 
-  private final KafkaService kafkaService;
+  private final KafkaModuleFactory kafkaModuleFactory;
 
-  public KafkaApplicationService(final KafkaService kafkaService) {
-    this.kafkaService = kafkaService;
+  public KafkaApplicationService(final DockerImages dockerImages) {
+    this.kafkaModuleFactory = new KafkaModuleFactory(dockerImages);
   }
 
-  public void init(final Project project) {
-    kafkaService.init(project);
+  public JHipsterModule init(final JHipsterModuleProperties properties) {
+    return kafkaModuleFactory.buildModuleInit(properties);
   }
 
-  public void addDummyProducerConsumer(final Project project) {
-    kafkaService.addDummyProducerConsumer(project);
+  public JHipsterModule addDummyProducerConsumer(final JHipsterModuleProperties properties) {
+    return kafkaModuleFactory.buildModuleDummyProducerConsumer(properties);
   }
 
-  public void addAkhq(final Project project) {
-    kafkaService.addAkhq(project);
+  public JHipsterModule addAkhq(final JHipsterModuleProperties properties) {
+    return kafkaModuleFactory.buildModuleAkhq(properties);
   }
 }