Update apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/SinglePartitionIntegrationTest.java

aamolgote · theangrydev · web-flow · commit 1394665355ba · 2023-11-04T16:46:09.000-04:00
Co-authored-by: Liam Williams &lt;liam.williams@zoho.com&gt;
diff --git a/apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/SinglePartitionIntegrationTest.java b/apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/SinglePartitionIntegrationTest.java
@@ -68,18 +68,7 @@ static void setup() throws ExecutionException, InterruptedException {
         admin = Admin.create(adminProperties);
 
 
-        List<NewTopic> topicList = new ArrayList<>();
-        NewTopic newTopic = new NewTopic(Config.SINGLE_PARTITION_TOPIC, Config.SINGLE_PARTITION, Config.REPLICATION_FACTOR);
-        topicList.add(newTopic);
-        CreateTopicsResult result = admin.createTopics(topicList);
-        KafkaFuture<Void> future = result.values().get(Config.SINGLE_PARTITION_TOPIC);
-        future.whenComplete((voidResult, exception) -> {
-            if (exception != null) {
-                System.err.println("Error creating the topic: " + exception.getMessage());
-            } else {
-                System.out.println("Topic created successfully!");
-            }
-        }).get();
+        admin.createTopics(ImmutableList.of(new NewTopic(Config.SINGLE_PARTITION_TOPIC, Config.SINGLE_PARTITION, Config.REPLICATION_FACTOR))).all().get();
     }
 
     @AfterAll
