fix(emulator): formatting issues

jeqo · Jul 21, 2022 · 5ffd6cb · 5ffd6cb
1 parent a70b169
commit 5ffd6cb
Showing 1 changed file with 16 additions and 3 deletions.
diff --git 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()
               );