X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FEndlessProducer.java;h=7a5b324e144fddbaef84c036640e62448c6f7a4f;hb=958835b95ba4edd3f299d8be42e510fe750e6356;hp=33a3815ce0e69d1f5ba1ff2ea91b86fa606b17ca;hpb=5802d9946f89715b86ca06858ee76d72dc3d275a;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/EndlessProducer.java b/src/main/java/de/juplo/kafka/EndlessProducer.java
index 33a3815..7a5b324 100644
--- a/src/main/java/de/juplo/kafka/EndlessProducer.java
+++ b/src/main/java/de/juplo/kafka/EndlessProducer.java
@@ -90,7 +90,7 @@ public class EndlessProducer implements Runnable
     final long time = System.currentTimeMillis();
 
     final ProducerRecord<String, String> record = new ProducerRecord<>(
-        "test", // Topic
+        topic,  // Topic
         key,    // Key
         value   // Value
     );