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=d9c7661eba0c2b510b43034c983b31e7b1e2fc96;hb=6d6877ff078d4fa9d4709f8ff497488abded231b;hp=33dabc93f8c1972662157b0f83a7b5827c969094;hpb=656d24e02b7e42404a508946885009b59b39e1ee;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 33dabc9..d9c7661 100644
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -23,6 +23,7 @@ public class ApplicationConfiguration
         new RestGateway(
             properties.getClientId(),
             properties.getTopic(),
+            properties.getPartition(),
             kafkaProducer);
   }