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=da1605bee122fe7f83229a14410de53abd3e997a;hb=818c1eb862247e25abf9f7d91d5a73e3e3789a39;hp=b077a90efc137edc525dc5d57ccc7174b00c5091;hpb=2d84eda74475aaffff11ddfebe56d309b9aff2e9;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 b077a90..da1605b 100644
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -32,10 +32,18 @@ public class ApplicationConfiguration
         consumer);
   }
 
+  @Bean
+  public WordcountRebalanceListener wordcountRebalanceListener(
+      WordcountRecordHandler wordcountRecordHandler)
+  {
+    return new WordcountRebalanceListener(wordcountRecordHandler);
+  }
+
   @Bean
   public EndlessConsumer<String, String> endlessConsumer(
       KafkaConsumer<String, String> kafkaConsumer,
       ExecutorService executor,
+      WordcountRebalanceListener wordcountRebalanceListener,
       WordcountRecordHandler wordcountRecordHandler,
       ApplicationProperties properties)
   {
@@ -45,6 +53,7 @@ public class ApplicationConfiguration
             properties.getClientId(),
             properties.getTopic(),
             kafkaConsumer,
+            wordcountRebalanceListener,
             wordcountRecordHandler);
   }