Thanks,
On Thu, Nov 10, 2022 at 6:21 PM Gen Luo wrote
>
> I suppose it would be fine. The only difference I can figure out that may
> matter is the serialization. Flink uses KryoSerializer as the fallback
> serializer if the TypeInformation of the records is not provided, which can
> properly pro
Greetings,
I am looking at Flink pipeline processing events consumed from a Kafka
topic, which now needs to also consume events which have a different, but
related, schema. Traditional Java OOP would suggest transitioning from
class Dog { ... }
new FilterFunction { ... }
to
abstract class Animal
