diff --git a/kafka-ui-api/src/test/java/com/provectus/kafka/ui/emitter/MessageFiltersTest.java b/kafka-ui-api/src/test/java/com/provectus/kafka/ui/emitter/MessageFiltersTest.java index ded921bfcd..0986a292ef 100644 --- a/kafka-ui-api/src/test/java/com/provectus/kafka/ui/emitter/MessageFiltersTest.java +++ b/kafka-ui-api/src/test/java/com/provectus/kafka/ui/emitter/MessageFiltersTest.java @@ -140,7 +140,7 @@ class MessageFiltersTest { @Test - void filterSpeedIsAtLeast10kPerSec() { + void filterSpeedIsAtLeast5kPerSec() { var f = groovyScriptFilter("value.name.first == 'user1' && keyAsText.startsWith('a') "); List toFilter = new ArrayList<>(); @@ -159,7 +159,7 @@ class MessageFiltersTest { long matched = toFilter.stream().filter(f).count(); long took = System.currentTimeMillis() - before; - assertThat(took).isLessThan(500); + assertThat(took).isLessThan(1000); assertThat(matched).isGreaterThan(0); } }