Estoy mirando las corrientes de kafka. Quiero filtrar mi flujo, usando un filtro con muy baja selectividad (uno en unos pocos miles). Estaba mirando este método:https://kafka.apache.org/0100/javadoc/org/apache/kafka/streams/kstream/KStream.html#filter(org.apache.kafka.streams.kstream.Predicate)

Pero no puedo encontrar ninguna evidencia, si el filtro será evaluado por el consumidor (realmente no quiero transferir una gran cantidad de GB al consumidor, solo para tirarlos), o dentro del corredor (¡sí!).

Si se evalúa en el lado del consumidor, ¿hay alguna forma de hacer esto en el corredor?

¡Gracias!