From dcb6dc0f00da7bbfdf4a79b9a8edf2341a30b1eb Mon Sep 17 00:00:00 2001 From: svroonland Date: Tue, 12 Nov 2024 20:53:38 +0100 Subject: [PATCH] Update zio-kafka/src/main/scala/zio/kafka/consumer/internal/PartitionStreamControl.scala Co-authored-by: Erik van Oosten --- .../zio/kafka/consumer/internal/PartitionStreamControl.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/zio-kafka/src/main/scala/zio/kafka/consumer/internal/PartitionStreamControl.scala b/zio-kafka/src/main/scala/zio/kafka/consumer/internal/PartitionStreamControl.scala index 84bf7bb78..cde72d9a6 100644 --- a/zio-kafka/src/main/scala/zio/kafka/consumer/internal/PartitionStreamControl.scala +++ b/zio-kafka/src/main/scala/zio/kafka/consumer/internal/PartitionStreamControl.scala @@ -86,7 +86,7 @@ final class PartitionStreamControl private ( /** To be invoked when the stream is no longer processing. */ private[internal] def halt: UIO[Unit] = { - val timeOutMessage = s"No records were polled for more than $maxStreamPullInterval for topic partition $tp. " + + val timeOutMessage = s"No records were pulled for more than $maxStreamPullInterval for topic partition $tp. " + "Use ConsumerSettings.withMaxPollInterval to set a longer interval if processing a batch of records " + "needs more time." val consumeTimeout = new TimeoutException(timeOutMessage) with NoStackTrace