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 (file)
--- 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) ->
     {