From fb7d3c298423eaf04b73d54e6232d0ab0696101e Mon Sep 17 00:00:00 2001
From: Nuno Neto <nunoarneto@gmail.com>
Date: Fri, 8 Sep 2023 18:26:22 +0100
Subject: [PATCH] Fix identention

---
 .../kafka/client/runtime/KafkaAdminClient.java       | 12 ++++++------
 .../client/runtime/devui/KafkaJsonRPCService.java    | 11 ++++++-----
 .../devui/model/request/KafkaCreateTopicRequest.java |  2 +-
 3 files changed, 13 insertions(+), 12 deletions(-)

diff --git a/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/KafkaAdminClient.java b/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/KafkaAdminClient.java
index 1f4b6ac8f763d..e4fbf4dce9af6 100644
--- a/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/KafkaAdminClient.java
+++ b/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/KafkaAdminClient.java
@@ -55,10 +55,10 @@ public Collection<TopicListing> getTopics() throws InterruptedException, Executi
 
     public Collection<ConsumerGroupDescription> getConsumerGroups() throws InterruptedException, ExecutionException {
         var consumerGroupIds = client.listConsumerGroups().all().get().stream()
-            .map(ConsumerGroupListing::groupId)
-            .collect(Collectors.toList());
+                .map(ConsumerGroupListing::groupId)
+                .collect(Collectors.toList());
         return client.describeConsumerGroups(consumerGroupIds).all().get()
-            .values();
+                .values();
     }
 
     public boolean deleteTopic(final String name) {
@@ -88,9 +88,9 @@ public Collection<AclBinding> getAclInfo() throws InterruptedException, Executio
     }
 
     public Map<String, TopicDescription> describeTopics(final Collection<String> topicNames)
-        throws InterruptedException, ExecutionException {
+            throws InterruptedException, ExecutionException {
         return client.describeTopics(topicNames)
-            .allTopicNames()
-            .get();
+                .allTopicNames()
+                .get();
     }
 }
diff --git a/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/devui/KafkaJsonRPCService.java b/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/devui/KafkaJsonRPCService.java
index 23469fd60eb4f..b5fe4ebdd3fcf 100644
--- a/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/devui/KafkaJsonRPCService.java
+++ b/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/devui/KafkaJsonRPCService.java
@@ -30,11 +30,12 @@ public List<KafkaTopic> getTopics() throws InterruptedException, ExecutionExcept
         return kafkaUiUtils.getTopics();
     }
 
-    public List<KafkaTopic> createTopic(final String topicName, final int partitions, final int replications, Map<String, String> configs)
-        throws InterruptedException, ExecutionException {
+    public List<KafkaTopic> createTopic(final String topicName, final int partitions, final int replications,
+            Map<String, String> configs)
+            throws InterruptedException, ExecutionException {
 
         KafkaCreateTopicRequest createTopicRequest = new KafkaCreateTopicRequest(topicName, partitions, (short) replications,
-            configs);
+                configs);
         boolean created = kafkaAdminClient.createTopic(createTopicRequest);
         if (created) {
             return kafkaUiUtils.getTopics();
@@ -59,8 +60,8 @@ public KafkaMessagePage topicMessages(final String topicName) throws ExecutionEx
     }
 
     public KafkaMessagePage createMessage(String topicName, Integer partition, String key, String value,
-        Map<String, String> headers)
-        throws ExecutionException, InterruptedException {
+            Map<String, String> headers)
+            throws ExecutionException, InterruptedException {
 
         if (partition < 0)
             partition = null;
diff --git a/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/devui/model/request/KafkaCreateTopicRequest.java b/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/devui/model/request/KafkaCreateTopicRequest.java
index 72e54ad933a29..883a6ba1ecaa4 100644
--- a/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/devui/model/request/KafkaCreateTopicRequest.java
+++ b/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/devui/model/request/KafkaCreateTopicRequest.java
@@ -12,7 +12,7 @@ public KafkaCreateTopicRequest() {
     }
 
     public KafkaCreateTopicRequest(final String topicName, final Integer partitions, final Short replications,
-        final Map<String, String> configs) {
+            final Map<String, String> configs) {
         this.topicName = topicName;
         this.partitions = partitions;
         this.replications = replications;