X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FSimpleProducer.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FSimpleProducer.java;h=43a72275c88bfd82e47b314d077363133e44cd41;hb=953aaf06ac7238fd693603ea6dac8b05eccd5f2d;hp=357e07a93e4de5b5b1c80e29076a7d4ba7c128f4;hpb=1b7afcf70fea7922f795ededaaec9277dacd9ffd;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/SimpleProducer.java b/src/main/java/de/juplo/kafka/SimpleProducer.java
index 357e07a..43a7227 100644
--- 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
     );