From 953aaf06ac7238fd693603ea6dac8b05eccd5f2d Mon Sep 17 00:00:00 2001 From: Kai Moritz 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 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 record = new ProducerRecord<>( - "test", // Topic + topic, // Topic key, // Key value // Value ); -- 2.20.1