Beispiele verwenden das Interface, um die erzeugte Instanz abzulegen

[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 357e07a..9a1d5d6 100644 (file)
--- a/src/main/java/de/juplo/kafka/SimpleProducer.java
+++ b/src/main/java/de/juplo/kafka/SimpleProducer.java
@@ -1,6 +1,7 @@
 package de.juplo.kafka;
 
 import lombok.extern.slf4j.Slf4j;
+import org.apache.kafka.clients.producer.Producer;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.StringSerializer;
@@ -15,7 +16,7 @@ public class SimpleProducer
 {
   private final String id;
   private final String topic;
-  private final KafkaProducer<String, String> producer;
+  private final Producer<String, String> producer;
 
   private long produced = 0;
 
@@ -27,7 +28,7 @@ public class SimpleProducer
     props.put("key.serializer", StringSerializer.class.getName());
     props.put("value.serializer", StringSerializer.class.getName());
 
-    KafkaProducer<String, String> producer = new KafkaProducer<>(props);
+    Producer<String, String> producer = new KafkaProducer<>(props);
     // end::create[]
 
     this.id = clientId;
@@ -61,7 +62,7 @@ public class SimpleProducer
     final long time = System.currentTimeMillis();
 
     final ProducerRecord<String, String> record = new ProducerRecord<>(
-        "test", // Topic
+        topic,  // Topic
         key,    // Key
         value   // Value
     );