From 953aaf06ac7238fd693603ea6dac8b05eccd5f2d Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 25 Mar 2022 15:27:50 +0100
Subject: [PATCH] =?utf8?q?F=C3=A4lschlich=20hartkodiertes=20Topic=20gegen?=
=?utf8?q?=20Variable=20getauscht?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit
---
src/main/java/de/juplo/kafka/SimpleProducer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/src/main/java/de/juplo/kafka/SimpleProducer.java b/src/main/java/de/juplo/kafka/SimpleProducer.java
index 357e07a9..43a72275 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
);
--
2.20.1