From: Kai Moritz <kai@juplo.de>
Date: Fri, 25 Mar 2022 14:27:50 +0000 (+0100)
Subject: Fälschlich hartkodiertes Topic gegen Variable getauscht
X-Git-Tag: notnagel~7^2
X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Ftraining;a=commitdiff_plain;h=953aaf06ac7238fd693603ea6dac8b05eccd5f2d

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 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
     );