Package io.confluent.telemetry.events.exporter.kafka

Class EventRouteFilter

java.lang.Object

io.confluent.telemetry.events.exporter.kafka.EventRouteFilter

All Implemented Interfaces:

Predicate<io.confluent.telemetry.api.events.Event>

public class EventRouteFilter
extends Object
implements Predicate<io.confluent.telemetry.api.events.Event>

An event filter that filters based on the route extension.

Constructor Summary

Constructors

Constructor	Description
EventRouteFilter(String... allowedRoutes)
EventRouteFilter(Collection<String> allowedRoutes)

Method Summary

Modifier and Type	Method	Description
boolean	test(io.confluent.telemetry.api.events.Event event)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Predicate

and, negate, or

Constructor Details

EventRouteFilter

public EventRouteFilter(String... allowedRoutes)

EventRouteFilter

public EventRouteFilter(Collection<String> allowedRoutes)

Method Details

test

public boolean test(io.confluent.telemetry.api.events.Event event)

Specified by:

test in interface Predicate<io.confluent.telemetry.api.events.Event>