diff --git a/data-plane/benchmarks/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/AllFilterBenchmark.java b/data-plane/benchmarks/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/AllFilterBenchmark.java index eeef087af5..2faff3027e 100644 --- a/data-plane/benchmarks/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/AllFilterBenchmark.java +++ b/data-plane/benchmarks/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/AllFilterBenchmark.java @@ -27,7 +27,7 @@ public class AllFilterBenchmark { public static ExactFilter makeExactFilter() { - return new ExactFilter(Map.of("id", "com.github.pull.create")); + return new ExactFilter(Map.of("type", "com.github.pull.create")); } public static PrefixFilter makePrefixFilter() { diff --git a/data-plane/benchmarks/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/AnyFilterBenchmark.java b/data-plane/benchmarks/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/AnyFilterBenchmark.java index 30a6cc3669..702bc75d7f 100644 --- a/data-plane/benchmarks/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/AnyFilterBenchmark.java +++ b/data-plane/benchmarks/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/AnyFilterBenchmark.java @@ -33,7 +33,7 @@ public static CloudEvent event() { } public static ExactFilter makeExactFilter() { - return new ExactFilter(Map.of("id", "com.github.pull.create")); + return new ExactFilter(Map.of("type", "com.github.pull.create")); } public static PrefixFilter makePrefixFilter() { diff --git a/data-plane/benchmarks/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/FilterBenchmark.java b/data-plane/benchmarks/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/FilterBenchmark.java index 28ae301a4b..bc29350bad 100644 --- a/data-plane/benchmarks/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/FilterBenchmark.java +++ b/data-plane/benchmarks/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/FilterBenchmark.java @@ -22,20 +22,22 @@ import org.openjdk.jmh.annotations.*; import org.openjdk.jmh.infra.Blackhole; -@BenchmarkMode(Mode.All) +@BenchmarkMode(Mode.Throughput) @Fork(1) @State(Scope.Thread) +@Measurement(iterations = 3, time = 10) +@Warmup(iterations = 3, time = 5) @OutputTimeUnit(TimeUnit.MICROSECONDS) public abstract class FilterBenchmark { Filter filter; CloudEvent cloudEvent; - @Setup + @Setup(Level.Trial) public void setupFilter() { this.filter = createFilter(); } - @Setup + @Setup(Level.Trial) public void setupCloudEvent() { this.cloudEvent = createEvent(); }