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