How can I conditionally deserialize a Kafka message based on some condition?
I have avro definitions for a number of events, one of which is a record which contains a union type of a number of other events. Using a simple example to illustrate:
I have avro definitions for a number of events, one of which is a record which contains a union type of a number of other events. Using a simple example to illustrate: