Fix style

zio · Jan 11, 2025 · 1fca166 · 1fca166
1 parent 396657c
commit 1fca166
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/zio-kafka/src/main/scala/zio/kafka/consumer/ConsumerSettings.scala b/zio-kafka/src/main/scala/zio/kafka/consumer/ConsumerSettings.scala
@@ -334,13 +334,13 @@ final case class ConsumerSettings(
   /**
    * Controls how to consume records produced transactionally.
    *
-   * @param read_committed
+   * @param readCommitted
    *   when `true`, only consume records which have been committed, when `false`, consume all records, even records
    *   which are part of an aborted transaction. Non-transactional records will be consumed unconditionally in either
    *   mode.
    */
-  def withConsumeTransactionalOnly(read_committed: Boolean = true): ConsumerSettings = {
-    val isolationLevel = if (read_committed) IsolationLevel.READ_COMMITTED else IsolationLevel.READ_UNCOMMITTED
+  def withConsumeTransactionalOnly(readCommitted: Boolean = true): ConsumerSettings = {
+    val isolationLevel = if (readCommitted) IsolationLevel.READ_COMMITTED else IsolationLevel.READ_UNCOMMITTED
     withProperty(ConsumerConfig.ISOLATION_LEVEL_CONFIG, isolationLevel.toString)
   }