From 5ffd6cb3648d391b637aeb3e65a6e693f355e12e Mon Sep 17 00:00:00 2001
From: Jorge Esteban Quilcate Otoya <quilcate.jorge@gmail.com>
Date: Thu, 21 Jul 2022 09:34:46 +0100
Subject: [PATCH] fix(emulator): formatting issues

---
 .../kafka/cli/emulator/KafkaEmulator.java     | 19 ++++++++++++++++---
 1 file changed, 16 insertions(+), 3 deletions(-)

diff --git a/emulator/src/main/java/kafka/cli/emulator/KafkaEmulator.java b/emulator/src/main/java/kafka/cli/emulator/KafkaEmulator.java
index 48d2552..f796a0a 100644
--- a/emulator/src/main/java/kafka/cli/emulator/KafkaEmulator.java
+++ b/emulator/src/main/java/kafka/cli/emulator/KafkaEmulator.java
@@ -220,17 +220,30 @@ public void replay(
         for (var r : rs) {
           // prepare record
           final var topicName = topicMap.getOrDefault(r.topic(), r.topic());
-          var record = new ProducerRecord<>(topicName, r.partition(), prevTime + r.afterMs(), r.key(), r.value());
+          var record = new ProducerRecord<>(
+            topicName,
+            r.partition(),
+            prevTime + r.afterMs(),
+            r.key(),
+            r.value()
+          );
           try {
             // wait
             var wait = (prevTime + r.afterMs()) - System.currentTimeMillis();
             if (!noWait && wait > 0) {
-              LOG.info("{}:{}:{}: waiting {} ms.", topicName, r.partition(), r.offset(), r.afterMs());
+              LOG.info(
+                "{}:{}:{}: waiting {} ms.",
+                topicName,
+                r.partition(),
+                r.offset(),
+                r.afterMs()
+              );
               Thread.sleep(r.afterMs());
             } else {
               LOG.info(
                 "{}:{}:{}: no waiting (expected after: {} ms.)",
-                topicName, r.partition(),
+                topicName,
+                r.partition(),
                 r.offset(),
                 r.afterMs()
               );