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
index 8e6fdc2fa..83a44d7e7 100644
--- 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
    */