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 43a7227..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;