X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fimplementation%2Fkafka%2FConsumerTaskExecutor.java;h=881dd2930840c2a381f5fdc1b372b11ca2c9fcf2;hb=f3d558866e0f2a1cb002b558f3d094159a31daf5;hp=9ebc26b27a9bd2a1b1fb90e99931eb66ffba07e3;hpb=46ba1885fe43ef5f0f9b845f22cd61d707df94cc;p=demos%2Fkafka%2Fchat

diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskExecutor.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskExecutor.java
index 9ebc26b2..881dd293 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskExecutor.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskExecutor.java
@@ -46,7 +46,7 @@ public class ConsumerTaskExecutor
   }
 
 
-  interface WorkAssignor
+  public interface WorkAssignor
   {
     void assignWork(Consumer<?, ?> consumer);
   }