From: Kai Moritz <kai@juplo.de>
Date: Sun, 3 Apr 2022 16:30:46 +0000 (+0200)
Subject: Vorlage
X-Git-Tag: customized--vorlage---lvm-2-tage~1
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=69d126df4f6e4510bbbcfe19cc265109cfcb9b89;p=demos%2Fkafka%2Ftraining

Vorlage
---

diff --git a/src/main/java/de/juplo/kafka/RestProducer.java b/src/main/java/de/juplo/kafka/RestProducer.java
index ac9a541..b89802b 100644
--- a/src/main/java/de/juplo/kafka/RestProducer.java
+++ b/src/main/java/de/juplo/kafka/RestProducer.java
@@ -53,12 +53,9 @@ public class RestProducer
 
     final long time = System.currentTimeMillis();
 
-    final ProducerRecord<String, String> record = new ProducerRecord<>(
-        topic,  // Topic
-        partition, // Partition
-        key,    // Key
-        value   // Value
-    );
+    // TODO: Nachricht an eine fixe Partition versenden, wenn partition != null
+    //       Ansonsten wie bisher an eine über den Schlüssel gewählte
+    final ProducerRecord<String, String> record = null;
 
     producer.send(record, (metadata, e) ->
     {