From 5761287f6d9f9033fbe4d599466f95998bc76a24 Mon Sep 17 00:00:00 2001 From: Ben Plommer Date: Mon, 23 Aug 2021 08:52:56 +0100 Subject: [PATCH] Final def --- .../core/src/main/scala/fs2/kafka/consumer/KafkaConsume.scala | 2 +- 1 file changed, 1 insertion(+), 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 index bcc4c72b1..1e644773a 100644 --- 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 /**