Übung an die Übung `first-contact` angepasst

[demos/kafka/training] / src / main / java / de / juplo / kafka / SimpleProducer.java

diff --git a/src/main/java/de/juplo/kafka/SimpleProducer.java b/src/main/java/de/juplo/kafka/SimpleProducer.java
index 9e3bad7..db554d7 100644 (file)
--- a/src/main/java/de/juplo/kafka/SimpleProducer.java
+++ b/src/main/java/de/juplo/kafka/SimpleProducer.java
@@ -28,10 +28,9 @@ public class SimpleProducer
     props.put("key.serializer", StringSerializer.class.getName());
     props.put("value.serializer", StringSerializer.class.getName());
 
-    producer = new KafkaProducer<>(props);
-
-    this.topic = topic;
     this.id = clientId;
+    this.topic = topic;
+    producer = new KafkaProducer<>(props);
   }
 
   public void run()