kafka: adjusts

Author: mshima

generators/spring-cloud/generators/kafka/__snapshots__/generator.spec.ts.snap

@@ -67,6 +67,23 @@ exports[`generator - spring-cloud:kafka with defaults options should call source
       "name": "org.I0Itec",
     },
   ],
+  "editJavaFile": [
+    [
+      "src/test/java/com/mycompany/myapp/IntegrationTest.java",
+      {
+        "annotations": [
+          {
+            "annotation": "ImportTestcontainers",
+            "package": "org.springframework.boot.testcontainers.context",
+            "parameters": [Function],
+          },
+        ],
+        "imports": [
+          "com.mycompany.myapp.config.KafkaTestContainer",
+        ],
+      },
+    ],
+  ],
 }
 `;
 
@@ -93,8 +110,5 @@ exports[`generator - spring-cloud:kafka with defaults options should match files
   "src/test/java/com/mycompany/myapp/web/rest/JhipsterKafkaResourceIT.java": {
     "stateCleared": "modified",
   },
-  "src/test/resources/config/application-kafka.yml": {
-    "stateCleared": "modified",
-  },
 }
 `;

generators/spring-cloud/generators/kafka/generator.ts

@@ -93,9 +93,6 @@ export default class KafkaGenerator extends SpringBootApplicationGenerator {
                   },
                 ],
               }),
-              javaTestResourceTemplatesBlock({
-                templates: ['config/application-kafka.yml'],
-              }),
             ],
           },
           context: application,
@@ -115,6 +112,18 @@ export default class KafkaGenerator extends SpringBootApplicationGenerator {
         source.addTestLog?.({ name: 'kafka', level: 'WARN' });
         source.addTestLog?.({ name: 'org.I0Itec', level: 'WARN' });
       },
+      integrationTest({ application, source }) {
+        source.editJavaFile!(`${application.javaPackageTestDir}IntegrationTest.java`, {
+          imports: [`${application.packageName}.config.KafkaTestContainer`],
+          annotations: [
+            {
+              package: 'org.springframework.boot.testcontainers.context',
+              annotation: 'ImportTestcontainers',
+              parameters: (_, cb) => cb.addKeyValue('value', 'KafkaTestContainer.class'),
+            },
+          ],
+        });
+      },
       addDependencies({ source }) {
         source.addJavaDependencies?.([
           {