Hi, I am using 1.7 on K8S.
I have a huge amount of data in kafka, but I only need a tiny portion of it.
It is a keyed stream, the value in JSON encoded. I want to avoid deserialization of the value, since it is very expensive. Can I only filter based on the key?
I know there is a KeyedDeserializationSchema, but can I use it to filter data?
1019 Market St. 7F
San Francisco, CA 94103