diff --git a/src/main/scala/aserralle/akka/stream/kcl/Errors.scala b/src/main/scala/aserralle/akka/stream/kcl/Errors.scala
index 50036a8..c64c083 100644
--- a/src/main/scala/aserralle/akka/stream/kcl/Errors.scala
+++ b/src/main/scala/aserralle/akka/stream/kcl/Errors.scala
@@ -5,8 +5,11 @@
 package aserralle.akka.stream.kcl
 
 object Errors {
+  sealed class KinesisWorkerSourceError(err: Throwable) extends Throwable(err)
+
   case class WorkerUnexpectedShutdown(cause: Throwable)
-      extends Throwable(cause)
+      extends KinesisWorkerSourceError(cause)
 
-  case class BackpressureTimeout(cause: Throwable) extends Throwable(cause)
+  case class BackpressureTimeout(cause: Throwable)
+      extends KinesisWorkerSourceError(cause)
 }