Skip to content

Commit

Permalink
Update zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.s…
Browse files Browse the repository at this point in the history
…cala

Co-authored-by: Erik van Oosten <e.vanoosten@grons.nl>
  • Loading branch information
svroonland and erikvanoosten authored Nov 6, 2024
1 parent 9caee50 commit e034b77
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -175,7 +175,7 @@ private[consumer] final class Runloop private (
getStreamCompletionStatuses(newCommits).flatMap { completionStatuses =>
ZIO
.logWarning(
s"Exceeded deadline waiting for streams to end, will continue with rebalance: ${completionStatuses.map(_.toString).mkString("; ")}"
s"Exceeded deadline waiting for streams to commit the offsets of the records they consumed; the rebalance will continue. This might cause another consumer to process some records again. ${completionStatuses.map(_.toString).mkString("; ")}"
)
}
.unless(completed)
Expand Down

0 comments on commit e034b77

Please sign in to comment.