Address reviewer comments

zio · Jan 11, 2025 · 2109932 · 2109932
1 parent 00ff72c
commit 2109932
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/zio-kafka/src/main/scala/zio/kafka/consumer/ConsumerSettings.scala b/zio-kafka/src/main/scala/zio/kafka/consumer/ConsumerSettings.scala
@@ -339,7 +339,7 @@ final case class ConsumerSettings(
    *   which are part of an aborted transaction. Non-transactional records will be consumed unconditionally in either
    *   mode.
    */
-  def withConsumeTransactionalOnly(readCommitted: Boolean = true): ConsumerSettings = {
+  def withIsolationLevel(readCommitted: Boolean = true): ConsumerSettings = {
     val isolationLevel = if (readCommitted) IsolationLevel.READ_COMMITTED else IsolationLevel.READ_UNCOMMITTED
     withProperty(ConsumerConfig.ISOLATION_LEVEL_CONFIG, isolationLevel.toString)
   }