Improve NotSubscribedException message (#1303)

fd4s · Mar 4, 2024 · 5747be6 · 5747be6
1 parent 833ddec
commit 5747be6
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/modules/core/src/main/scala/fs2/kafka/NotSubscribedException.scala b/modules/core/src/main/scala/fs2/kafka/NotSubscribedException.scala
@@ -10,10 +10,11 @@ import org.apache.kafka.common.KafkaException
 
 /**
   * [[NotSubscribedException]] indicates that a `Stream` was started in [[KafkaConsumer]] even
-  * though the consumer had not been subscribed to any topics before starting.
+  * though the consumer had not been subscribed to any topics or assigned any partitions before
+  * starting.
   */
 sealed abstract class NotSubscribedException
-    extends KafkaException("consumer is not subscribed to any topics")
+    extends KafkaException("consumer is not subscribed to any topics or assigned any partitions")
 
 private[kafka] object NotSubscribedException {