diff --git a/src/main/java/io/statnett/k3a/topicterminator/strategy/InternalTopic.java b/src/main/java/io/statnett/k3a/topicterminator/strategy/InternalTopic.java index 90c8363..944e292 100644 --- a/src/main/java/io/statnett/k3a/topicterminator/strategy/InternalTopic.java +++ b/src/main/java/io/statnett/k3a/topicterminator/strategy/InternalTopic.java @@ -17,7 +17,7 @@ public InternalTopic(Set allNames) { } @Override - public Set getNames(AdminClient client) throws ExecutionException, InterruptedException { + public Set getNames(AdminClient client) { return allNames.stream() .filter(this::isInternal) .collect(Collectors.toSet());