Eu estou olhando para córregos kafka. Quero filtrar meu fluxo usando um filtro com seletividade muito baixa (um em poucos milhares). Eu estava olhando para este método:https://kafka.apache.org/0100/javadoc/org/apache/kafka/streams/kstream/KStream.html#filter(org.apache.kafka.streams.kstream.Predicate)

Mas não consigo encontrar nenhuma evidência, se o filtro for avaliado pelo consumidor (eu realmente não quero transferir muitos GB para o consumidor, apenas para jogá-los fora), ou dentro do broker (yay!).

Se for avaliado do lado do consumidor, existe alguma maneira de como fazer isso no broker?

Obrigado!