catch only non-fatal errors

sky-uk · Feb 28, 2022 · 42caac9 · 42caac9
1 parent 98fe20b
commit 42caac9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/scala/com/sky/kafka/topicloader/config/config.scala b/src/main/scala/com/sky/kafka/topicloader/config/config.scala
@@ -5,6 +5,7 @@ import cats.implicits._
 import com.typesafe.config.ConfigException
 
 import scala.util.Try
+import scala.util.control.NonFatal
 
 package object config {
   type ValidationResult[A] = ValidatedNec[ConfigException, A]
@@ -16,7 +17,8 @@ package object config {
   implicit class EitherOps[A](e: Either[Throwable, A]) {
     def validate(path: String): ValidationResult[A] = e.leftMap {
       case ce: ConfigException => ce
-      case e: Throwable        => new ConfigException.BadValue(path, e.getMessage)
+      case e if NonFatal(e)    => new ConfigException.BadValue(path, e.getMessage)
+      case e: Throwable        => throw e
     }.toValidatedNec
   }
 }