args formatting

eo-cqrs · May 8, 2023 · a2feef7 · a2feef7
1 parent 19674b2
commit a2feef7
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/src/main/java/io/github/eocqrs/kafka/consumer/KfConsumer.java b/src/main/java/io/github/eocqrs/kafka/consumer/KfConsumer.java
@@ -87,8 +87,9 @@ public void subscribe(final ConsumerRebalanceListener listener,
    * we have to wrap the ConsumerRecords into some object
    */
   @Override
-  public ConsumerRecords<K, X> records(final String topic,
-                                       final Duration timeout) {
+  public ConsumerRecords<K, X> records(
+    final String topic, final Duration timeout
+  ) {
     this.subscribe(topic);
     return this.origin.poll(timeout);
   }

diff --git a/src/main/java/io/github/eocqrs/kafka/fake/FkConsumer.java b/src/main/java/io/github/eocqrs/kafka/fake/FkConsumer.java
@@ -66,8 +66,9 @@ public void subscribe(final ConsumerRebalanceListener listener,
    * @todo #54:60m/DEV Fake records is not implemented
    */
   @Override
-  public ConsumerRecords<K, X> records(final String topic,
-                                       final Duration timeout) {
+  public ConsumerRecords<K, X> records(
+    final String topic, final Duration timeout
+  ) {
     throw new UnsupportedOperationException("#records()");
   }