Final def

fd4s · Aug 23, 2021 · 5761287 · 5761287
1 parent 720c4ff
commit 5761287
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaConsume.scala b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaConsume.scala
@@ -31,7 +31,7 @@ trait KafkaConsume[F[_], K, V] {
   /**
     * Alias for [[partitionedStream]]
     */
-  def partitionedRecords: Stream[F, Stream[F, CommittableConsumerRecord[F, K, V]]] =
+  final def partitionedRecords: Stream[F, Stream[F, CommittableConsumerRecord[F, K, V]]] =
     partitionedStream
 
   /**