Skip to content

Commit

Permalink
Update comment
Browse files Browse the repository at this point in the history
  • Loading branch information
svroonland committed Nov 10, 2024
1 parent 5ef97ef commit bec0e25
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala
Original file line number Diff line number Diff line change
Expand Up @@ -760,7 +760,7 @@ private[consumer] final class ConsumerLive private[consumer] (
.tapErrorCause(cause =>
ZIO.logErrorCause("Error joining withStream fiber in runWithGracefulShutdown", cause)
)
// Without the forkDaemon.flatMap(_.join) the above tapErrorCause will sometimes be triggered with interrupted fiber errors. The exact cause of that is unknown.
// Workaround for https://github.com/zio/zio/issues/9288
.forkDaemon
.flatMap(_.join)
.tapErrorCause(cause =>
Expand Down

0 comments on commit bec0e25

Please sign in to comment.