KafkaDevServicesDevModeTestCase instability fix : delete topic at app…

… startup

to avoid receiving records from previous execution

extensions/smallrye-reactive-messaging-kafka/deployment/src/test/java/io/quarkus/smallrye/reactivemessaging/kafka/deployment/dev/KafkaDevServicesDevModeTestCase.java

@@ -37,7 +37,7 @@ public class KafkaDevServicesDevModeTestCase {
                 @Override
                 public JavaArchive get() {
                     return ShrinkWrap.create(JavaArchive.class)
-                            .addClasses(PriceConverter.class, PriceResource.class, PriceGenerator.class)
+                            .addClasses(PriceConverter.class, PriceResource.class, PriceGenerator.class, TopicCleaner.class)
                             .addAsResource(new StringAsset(FINAL_APP_PROPERTIES),
                                     "application.properties");
                 }

extensions/smallrye-reactive-messaging-kafka/deployment/src/test/java/io/quarkus/smallrye/reactivemessaging/kafka/deployment/dev/TopicCleaner.java

@@ -0,0 +1,19 @@
+package io.quarkus.smallrye.reactivemessaging.kafka.deployment.dev;
+
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.enterprise.event.Observes;
+import jakarta.inject.Inject;
+
+import io.quarkus.kafka.client.runtime.KafkaAdminClient;
+import io.quarkus.runtime.StartupEvent;
+
+@ApplicationScoped
+public class TopicCleaner {
+
+    @Inject
+    KafkaAdminClient adminClient;
+
+    void startup(@Observes StartupEvent event) {
+        adminClient.deleteTopic("prices");
+    }
+}