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

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index d040f90..59652c0 100644
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -22,6 +22,7 @@ public class ApplicationConfiguration
     return
         new RestGateway(
             kafkaProperties.getClientId(),
+            applicationProperties.getTopic(),
             applicationProperties.getPartition(),
             kafkaTemplate);
   }