the `keyBy()` method automatically ensures that records with the same key will be processed by the same instance of a CoFlatMap.
As for the exception, I suppose the types `MessageType1` and `MessageType1` are POJOs which should follow some rules .
Also, make sure that (1) `property1` and `property2` are not arrays; (2) their types have overridden the `hashCode()` method .
Hope that helps,
On May 10, 2018, at 10:43 PM, Ishwara Varnasi <ivarnasi@xxxxxxxxx> wrote: