Merge der Überarbeitungen für die LVM-Schulung aus dem Branch 'customized'

[demos/kafka/training] / src / main / java / de / juplo / kafka / RestProducer.java

diff --git a/src/main/java/de/juplo/kafka/RestProducer.java b/src/main/java/de/juplo/kafka/RestProducer.java
index b5bb2d9..2706313 100644 (file)
--- a/src/main/java/de/juplo/kafka/RestProducer.java
+++ b/src/main/java/de/juplo/kafka/RestProducer.java
@@ -55,12 +55,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) ->
     {