catch null values

src/main/kotlin/KafkaTopology.kt

@@ -87,9 +87,6 @@ class KafkaTopology(
         val parsedStream = handledStream[1]
             .mapValues { value -> Pair(value.first, value.second) }
             .mapValues { readOnlyKey, value ->
-                log.warn("Key: {}", readOnlyKey)
-                log.warn("First Value: {}", value.first)
-                log.warn("Second Value as String: {}", String(value.second))
                 parse(readOnlyKey, value)
             }
             .branch(
@@ -236,6 +233,13 @@ class KafkaTopology(
         } catch (ex: KlaxonException) {
             log.error(ex.localizedMessage)
             Triple(null, null, Report(key, ReportStatus.failure, ex.localizedMessage))
+        } catch (ex: NullPointerException) {
+            log.error(ex.localizedMessage)
+            Triple(
+                null,
+                null,
+                Report(key, ReportStatus.failure, "There's no data to be processed: ${ex.localizedMessage}")
+            )
         }
     }
 }