From 69d126df4f6e4510bbbcfe19cc265109cfcb9b89 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 3 Apr 2022 18:30:46 +0200
Subject: [PATCH] Vorlage

---
 src/main/java/de/juplo/kafka/RestProducer.java | 9 +++------
 1 file changed, 3 insertions(+), 6 deletions(-)

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) ->
     {
-- 
2.20.1