Changeset 37:69db3b1e853d

Updated logging
author unexist
date Thu, 19 Aug 2021 14:04:04 +0200
parents fbdf12e636cb
children 1d48aca982d8
files event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitDispatcher.java
diffstat 1 files changed, 2 insertions(+), 2 deletions(-) [+]
line wrap: on
line diff
--- 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());