From bec0e259821e648519f48471c3a2a0fd04734469 Mon Sep 17 00:00:00 2001 From: Steven Vroonland Date: Sun, 10 Nov 2024 08:39:26 +0100 Subject: [PATCH] Update comment --- zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala b/zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala index bf714ed32..297341223 100644 --- a/zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala +++ b/zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala @@ -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 =>