From 68cf1231b464fc5f206145872244b40eabb174a8 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 1 Apr 2022 15:23:06 +0200 Subject: [PATCH] Vorlage --- .../java/de/juplo/kafka/EndlessProducer.java | 49 +------------------ 1 file changed, 1 insertion(+), 48 deletions(-) diff --git a/src/main/java/de/juplo/kafka/EndlessProducer.java b/src/main/java/de/juplo/kafka/EndlessProducer.java index 7a5b324..df5ff01 100644 --- a/src/main/java/de/juplo/kafka/EndlessProducer.java +++ b/src/main/java/de/juplo/kafka/EndlessProducer.java @@ -87,54 +87,7 @@ public class EndlessProducer implements Runnable void send(String key, String value) { - final long time = System.currentTimeMillis(); - - final ProducerRecord record = new ProducerRecord<>( - topic, // Topic - key, // Key - value // Value - ); - - producer.send(record, (metadata, e) -> - { - long now = System.currentTimeMillis(); - if (e == null) - { - // HANDLE SUCCESS - produced++; - log.debug( - "{} - Sent key={} message={} partition={}/{} timestamp={} latency={}ms", - id, - record.key(), - record.value(), - metadata.partition(), - metadata.offset(), - metadata.timestamp(), - now - time - ); - } - else - { - // HANDLE ERROR - log.error( - "{} - ERROR key={} timestamp={} latency={}ms: {}", - id, - record.key(), - metadata == null ? -1 : metadata.timestamp(), - now - time, - e.toString() - ); - } - }); - - long now = System.currentTimeMillis(); - log.trace( - "{} - Queued #{} key={} latency={}ms", - id, - value, - record.key(), - now - time - ); + // TODO: Die übergebene Nachricht versenden } public synchronized void start() -- 2.20.1