From 8f14291a52872141ded7ecead6b1f7f9fbc969e4 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sat, 12 Nov 2022 15:01:00 +0100 Subject: [PATCH] Konsumption der Nachricht in eine separate Methode verlagert MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit * Dies ist eine Vorbereitung für die Umstellung auf `@KafkaListener` * Durch die Umstellung wird der Code vor/nach der Umstellung besser vergleichbar. * Denn mit `@KafkaListener` wird direkt eine Methode annotiert, die dann von Spring die deserialisierte Nachricht injiziert bekommt. --- .../java/de/juplo/kafka/SimpleConsumer.java | 27 ++++++++++++------- 1 file changed, 17 insertions(+), 10 deletions(-) diff --git a/src/main/java/de/juplo/kafka/SimpleConsumer.java b/src/main/java/de/juplo/kafka/SimpleConsumer.java index 0e37686..1cf9b22 100644 --- a/src/main/java/de/juplo/kafka/SimpleConsumer.java +++ b/src/main/java/de/juplo/kafka/SimpleConsumer.java @@ -38,16 +38,12 @@ public class SimpleConsumer implements Runnable log.info("{} - Received {} messages", id, records.count()); for (ConsumerRecord record : records) { - consumed++; - log.info( - "{} - {}: {}/{} - {}={}", - id, - record.offset(), - record.topic(), - record.partition(), - record.key(), - record.value() - ); + handleRecord( + record.topic(), + record.partition(), + record.offset(), + record.key(), + record.value()); } } } @@ -67,4 +63,15 @@ public class SimpleConsumer implements Runnable log.info("{}: Consumed {} messages in total, exiting!", id, consumed); } } + + private void handleRecord( + String topic, + Integer partition, + Long offset, + String key, + String value) + { + consumed++; + log.info("{} - {}: {}/{} - {}={}", id, offset, topic, partition, key, value); + } } -- 2.20.1