#2663 Moving integration tests to "kafka" package

integration-tests/kafka/src/main/java/io/quarkus/it/kafka/KafkaStreamsPipeline.java

@@ -46,6 +46,7 @@
 import org.apache.kafka.streams.state.Stores;
 
 import io.quarkus.runtime.StartupEvent;
+
 @ApplicationScoped
 @Path("/kafkastreams")
 public class KafkaStreamsPipeline {
@@ -145,5 +146,5 @@ public Boolean call() throws Exception {
                 return topicNames.containsAll(Arrays.asList(expectedTopics));
             }
         };
-  }
+    }
 }

integration-tests/kafka/src/test/java/io/quarkus/it/main/KafkaConsumerITCase.java → integration-tests/kafka/src/test/java/io/quarkus/it/kafka/KafkaConsumerITCase.java

@@ -1,4 +1,4 @@
-package io.quarkus.it.main;
+package io.quarkus.it.kafka;
 
 import io.quarkus.test.junit.SubstrateTest;
 

integration-tests/kafka/src/test/java/io/quarkus/it/main/KafkaConsumerTest.java → integration-tests/kafka/src/test/java/io/quarkus/it/kafka/KafkaConsumerTest.java

@@ -1,4 +1,4 @@
-package io.quarkus.it.main;
+package io.quarkus.it.kafka;
 
 import java.util.Properties;
 

integration-tests/kafka/src/test/java/io/quarkus/it/main/KafkaProducerITCase.java → integration-tests/kafka/src/test/java/io/quarkus/it/kafka/KafkaProducerITCase.java

@@ -1,4 +1,4 @@
-package io.quarkus.it.main;
+package io.quarkus.it.kafka;
 
 import io.quarkus.test.junit.SubstrateTest;
 

integration-tests/kafka/src/test/java/io/quarkus/it/main/KafkaProducerTest.java → integration-tests/kafka/src/test/java/io/quarkus/it/kafka/KafkaProducerTest.java

@@ -1,4 +1,4 @@
-package io.quarkus.it.main;
+package io.quarkus.it.kafka;
 
 import java.time.Duration;
 import java.util.Collections;

integration-tests/kafka/src/test/java/io/quarkus/it/main/KafkaStreamsITCase.java → integration-tests/kafka/src/test/java/io/quarkus/it/kafka/KafkaStreamsITCase.java

@@ -1,4 +1,4 @@
-package io.quarkus.it.main;
+package io.quarkus.it.kafka;
 
 import io.quarkus.test.junit.SubstrateTest;
 

integration-tests/kafka/src/test/java/io/quarkus/it/main/KafkaStreamsTest.java → integration-tests/kafka/src/test/java/io/quarkus/it/kafka/KafkaStreamsTest.java

@@ -1,4 +1,4 @@
-package io.quarkus.it.main;
+package io.quarkus.it.kafka;
 
 import java.io.StringReader;
 import java.time.Duration;
@@ -159,7 +159,7 @@ private List<ConsumerRecord<Integer, String>> poll(Consumer<Integer, String> con
     }
 
     private JsonObject parse(String json) {
-        try(JsonReader reader = Json.createReader(new StringReader(json))) {
+        try (JsonReader reader = Json.createReader(new StringReader(json))) {
             return reader.readObject();
         }
     }

integration-tests/kafka/src/test/java/io/quarkus/it/main/KafkaTestResource.java → integration-tests/kafka/src/test/java/io/quarkus/it/kafka/KafkaTestResource.java

@@ -1,4 +1,4 @@
-package io.quarkus.it.main;
+package io.quarkus.it.kafka;
 
 import java.io.File;
 import java.util.Collections;