X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fimplementation%2Fkafka%2FKafkaTestUtils.java;h=1da6158bfe9bdc72f456c39dd9513c39a1df0e2f;hb=64ede95835a496e84857c38213dbf8ea451878e0;hp=ca30f667a8222520cd22bec03ccc4ceffb9ae4dc;hpb=a7a3d53e445556b56d4039fe1d5a00c294443e90;p=demos%2Fkafka%2Fchat

diff --git a/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java b/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java
index ca30f667..1da6158b 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java
@@ -71,9 +71,4 @@ public abstract class KafkaTestUtils
         value,
         new TopicPartition(result.getRecordMetadata().topic(), result.getRecordMetadata().partition()));
   }
-
-  public static void joinConsumerTasks(ChannelTaskRunner channelTaskRunner) throws InterruptedException
-  {
-    channelTaskRunner.joinChannel();
-  }
 }