spacing

responsivedev · Oct 25, 2024 · 4a2cea0 · 4a2cea0
1 parent 993c8eb
commit 4a2cea0
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/kafka-client/src/main/java/dev/responsive/kafka/internal/db/RemoteKVTable.java b/kafka-client/src/main/java/dev/responsive/kafka/internal/db/RemoteKVTable.java
@@ -38,7 +38,7 @@ KVFlushManager init(
    *
    * @param kafkaPartition  the kafka partition
    * @param key             the data key
-   * @param streamTimeMs   the current streamTime
+   * @param streamTimeMs    the current streamTime
    *
    * @return the value previously set
    */
@@ -56,7 +56,7 @@ KVFlushManager init(
    * @param kafkaPartition  the kafka partition
    * @param from            the starting key (inclusive)
    * @param to              the ending key (inclusive)
-   * @param streamTimeMs   the current streamTime
+   * @param streamTimeMs    the current streamTime
    *
    * @return an iterator of all key-value pairs in the range
    */
@@ -76,7 +76,7 @@ KeyValueIterator<Bytes, byte[]> range(
    * session).
    *
    * @param kafkaPartition  the kafka partition
-   * @param streamTimeMs   the current streamTime
+   * @param streamTimeMs    the current streamTime
    *
    * @return an iterator of all key-value pairs
    */