Fälschlich hartkodiertes Topic gegen Variable getauscht

diff --git a/src/main/java/de/juplo/kafka/SimpleProducer.java b/src/main/java/de/juplo/kafka/SimpleProducer.java
index 357e07a93e4de5b5b1c80e29076a7d4ba7c128f4..43a72275c88bfd82e47b314d077363133e44cd41 100644 (file)
--- a/src/main/java/de/juplo/kafka/SimpleProducer.java
+++ b/src/main/java/de/juplo/kafka/SimpleProducer.java
@@ -61,7 +61,7 @@ public class SimpleProducer
     final long time = System.currentTimeMillis();
 
     final ProducerRecord<String, String> record = new ProducerRecord<>(
-        "test", // Topic
+        topic,  // Topic
         key,    // Key
         value   // Value
     );