Vorlage
authorKai Moritz <kai@juplo.de>
Sun, 3 Apr 2022 16:30:46 +0000 (18:30 +0200)
committerKai Moritz <kai@juplo.de>
Wed, 3 Aug 2022 20:05:59 +0000 (22:05 +0200)
src/main/java/de/juplo/kafka/RestProducer.java

index ac9a541..b89802b 100644 (file)
@@ -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) ->
     {