WIP

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

diff --git a/src/main/java/de/juplo/kafka/RestGateway.java b/src/main/java/de/juplo/kafka/RestGateway.java
index 2f2b18c..96b9cd8 100644 (file)
--- 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();