Re: Skip event in case of key extraction exception
You cannot filter out events in the KeyExtractor. What you can do
though is to move the conversion logic to e.g. flatMap function and
emit only those events that where successfully converted. Then your
KeyExtractor would be a single getter for the UUID.
On 13/08/18 07:45, Jayant Ameta wrote:
key extraction logic requires a conversion from string to
UUID. I want to skip the event in case of exception. Is it