Речь шла о фильтрации внутри сервера (брокера), поэтому, когда у вас есть потоки со многими ГБ и низкой избирательностью, большая часть потока не достигает потребителей (приложений). Но KSQL и KStreams являются клиентскими библиотеками == полный поток достигает всех клиентов, и они выполняют фильтрацию.
трю в потоки Кафки. Я хочу отфильтровать свой поток, используя фильтр с очень низкой селективностью (один на несколько тысяч). Я смотрел на этот метод:https://kafka.apache.org/0100/javadoc/org/apache/kafka/streams/kstream/KStream.html#filter(org.apache.kafka.streams.kstream.Predicate)
Но я не могу найти никаких доказательств того, будет ли фильтр оценен потребителем (я действительно не хочу передавать много ГБ потребителю, просто чтобы выбросить их), или внутри брокера (ура!).
Если его оценить на стороне потребителя, есть ли способ, как это сделать в брокере?
Спасибо!