X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplication.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplication.java;h=944a7a72bb8ad03674d225fcd55a75a9a4942104;hb=0cf4b667026edf0587cc7a8c9698a025e112b600;hp=91b157a2264e6e567d0385172efd1e70340a46f9;hpb=42f65985a522b58775a691f3a9462c1eadca9e4d;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java
index 91b157a..944a7a7 100644
--- a/src/main/java/de/juplo/kafka/Application.java
+++ b/src/main/java/de/juplo/kafka/Application.java
@@ -23,7 +23,7 @@ public class Application implements ApplicationRunner
   void send(String key, String value)
   {
     ListenableFuture<SendResult<String, String>> listenableFuture =
-        kafkaTemplate.sendDefault(key, value);
+        kafkaTemplate.send("test", key, value);
 
     listenableFuture.addCallback(
         result -> log.debug(