# 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 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());