Catch saxon api exceptions.

src/main/kotlin/KafkaTopology.kt

@@ -22,6 +22,7 @@ import ch.memobase.kafka.utils.ConfigJoiner
 import ch.memobase.kafka.utils.models.ImportService
 import ch.memobase.kafka.utils.models.JoinedValues
 import com.beust.klaxon.Klaxon
+import net.sf.saxon.s9api.SaxonApiException
 import org.apache.kafka.common.serialization.Serdes
 import org.apache.kafka.streams.KeyValue
 import org.apache.kafka.streams.StreamsBuilder
@@ -119,7 +120,6 @@ class KafkaTopology(private val settings: SettingsLoader) {
                                 )
                             )
                         )
-
                     } catch (ex: MissingIdentifierException) {
                         log.error(ex.message)
                         KeyValue(
@@ -131,7 +131,17 @@ class KafkaTopology(private val settings: SettingsLoader) {
                                 )
                             )
                         )
-
+                    } catch (ex: SaxonApiException) {
+                        log.error(ex.message)
+                        KeyValue(
+                            key, Pair(
+                                null, Report(
+                                    key,
+                                    ReportStatus.failure,
+                                    ex.localizedMessage
+                                )
+                            )
+                        )
                     }
                 }
             }