X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FRestGateway.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FRestGateway.java;h=96b9cd8323b11f79625de4fbd02afecead0586e7;hb=e09650509adafd0b28f141ea1302fa27ba69b73a;hp=2f2b18c6448232309ad70da377b94667909743df;hpb=6952a12b00e8c5f015c8211c545bb2e022400c9b;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/RestGateway.java b/src/main/java/de/juplo/kafka/RestGateway.java
index 2f2b18c..96b9cd8 100644
--- a/src/main/java/de/juplo/kafka/RestGateway.java
+++ b/src/main/java/de/juplo/kafka/RestGateway.java
@@ -19,6 +19,7 @@ import org.springframework.web.context.request.async.DeferredResult;
 public class RestGateway
 {
   private final String id;
+  private final String topic;
   private final Integer partition;
   private final KafkaTemplate<String, Integer> kafkaTemplate;
 
@@ -35,7 +36,7 @@ public class RestGateway
     final long time = System.currentTimeMillis();
 
     ListenableFuture<SendResult<String, Integer>> future =
-        kafkaTemplate.send(null, partition, key, value);
+        kafkaTemplate.send(topic, partition, key, value);
 
     long now = System.currentTimeMillis();