I was exploring upcasting and I was wondering how to handle the case of events that have been published to Kafka that require upcasting. I was going through the code and it looks like the amqp and kafka modules do not support upcasting.
I can only think of two options so far:
- Upcast the events as they come in from Kafka
- Delete the topic and republish the upcasted event stream from the event store to kafka again
Both options would be problematic for existing consumers of the event log (Kafka).
Are these viable solutions? I’m hoping for more elegant alternatives.