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<Dog> { ... }
to
abstract class Animal { ... }
class Dog extends Animal { ... }
class Cat extends Animal { ... }
new FilterFunction<Animal> { ... }
but I am wondering if there is anything that might surprise the unwary down
that road, considering that the code base also uses asynchronous functions
and the broadcast pattern.
Thank you in advance,
Davide Bolcioni
--
There is no place like /home
