# HG changeset patch
# User unexist
# Date 1629374644 -7200
# Node ID 69db3b1e853d1fb6ea3bf2cbcdf056076ff147de
# Parent  fbdf12e636cb043105bc0efe7012c7ed3bec22a2
Updated logging

diff -r fbdf12e636cb -r 69db3b1e853d event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitDispatcher.java
--- a/event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitDispatcher.java	Thu Aug 19 13:26:58 2021 +0200
+++ b/event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitDispatcher.java	Thu Aug 19 14:04:04 2021 +0200
@@ -87,14 +87,14 @@
     private void handleMessage(KafkaConsumerRecord<String, String> record) {
         String typeName = StringUtils.EMPTY;
 
-        System.out.println("Handle message " + record.value());
+        LOGGER.info("Handle message {}", record.value());
 
         try {
             JsonNode json = MAPPER.readTree(record.value());
 
             typeName = json.get("type").asText();
         } catch (JsonProcessingException e) {
-            System.out.println("Error reading JSON " + e);
+            LOGGER.info("Error reading JSON", e);
         }
 
         this.bus.send(typeName, record.value());