From e54e2438422a648000482471de0561a42794d6a7 Mon Sep 17 00:00:00 2001 From: Eric Meisel Date: Tue, 12 Dec 2023 17:44:24 -0600 Subject: [PATCH] KCLConsumerFS2 should have autoCommit = false (#265) --- kcl/src/main/scala/kinesis4cats/kcl/fs2/KCLConsumerFS2.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/kcl/src/main/scala/kinesis4cats/kcl/fs2/KCLConsumerFS2.scala b/kcl/src/main/scala/kinesis4cats/kcl/fs2/KCLConsumerFS2.scala index b14023e9..4f202221 100644 --- a/kcl/src/main/scala/kinesis4cats/kcl/fs2/KCLConsumerFS2.scala +++ b/kcl/src/main/scala/kinesis4cats/kcl/fs2/KCLConsumerFS2.scala @@ -245,7 +245,9 @@ object KCLConsumerFS2 { F: Async[F], P: Parallel[F] ): Builder[F] = Builder( - config = KCLConsumer.BuilderConfig.Make.default(appName, streamTracker), + config = KCLConsumer.BuilderConfig.Make + .default(appName, streamTracker) + .andThen(_.withProcessConfig(defaultProcessConfig)), mkKinesisClient = Resource.fromAutoCloseable( Sync[F].delay(KinesisAsyncClient.create()) ),