Update zio-kafka/src/main/scala/zio/kafka/consumer/internal/Partition…

…StreamControl.scala Co-authored-by: Erik van Oosten <e.vanoosten@grons.nl>
zio · Nov 12, 2024 · dcb6dc0 · dcb6dc0
1 parent e6735c0
commit dcb6dc0
Showing 1 changed file with 1 addition and 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
@@ -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