From 2109932918c0965789b6efc99ad19ebf4488bdf4 Mon Sep 17 00:00:00 2001 From: Erik van Oosten Date: Sat, 11 Jan 2025 11:26:48 +0100 Subject: [PATCH] Address reviewer comments --- .../src/main/scala/zio/kafka/consumer/ConsumerSettings.scala | 2 +- 1 file changed, 1 insertion(+), 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 index 4c6f4bb95..ddab77e7c 100644 --- 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) }