KCLConsumerFS2 should have autoCommit = false (#265)

etspaceman · Dec 12, 2023 · e54e243 · e54e243
1 parent 5a51212
commit e54e243
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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())
       ),