2020-07-10 09:38:40 UTC - Sijie Guo: Currently it is not enforced by schemas yet. It should be straightforward to add this enforcement. ---- 2020-07-10 10:00:39 UTC - Ali Ahmed: are you asking how to filter messages in a consumer ? ---- 2020-07-10 10:30:43 UTC - andrius.antipovas: Yes. I am saving JSON messages in the topic. And with consumer I need to get only one message. For example get message with JSON node: code = 123 ---- 2020-07-10 23:15:15 UTC - Ali Ahmed: there is no filtering of messages in pulsar at the broker level you have read messages and filter them on client side or you can look into pulsar function to generate a filtered topic ----
