refactor: Separated channels for data and info -- Refactored/aligned code

[demos/kafka/chat] / src / main / java / de / juplo / kafka / chat / backend / implementation / kafka / ConsumerTaskExecutor.java

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 9ebc26b..881dd29 100644 (file)
--- 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);
   }
   {
     void assignWork(Consumer<?, ?> consumer);
   }