Всем привет, есть небольшой вопрос по поводу domain event и kafka.
Есть consumer который, слушает kafka и принимает сообщения, они приходят в json одни форматом, поэтому я повесил над классом ProductEvent аннотацию с Deserializer-ом, все вроде хорошо, но подумав немного, а если я буду работать с rest - и там будет другой формат данных, то мне нужно будет два deserualizer-a, но он у меня уже есть и подключается через аннотацию.
Проблема следующая - rest API и брокер сообщений, могут посылать одни и те же данные , с разной структурой, в чем тут ошибка?
Я вижу только три варианта:
- брокер сообщений, сделать так чтоб приложение отправляло такие же данные как и у rest,
- какой-нибудь api gateway, только как и где, не имею представления,
- сделать deserializer без аннотации и использовать вручную в методах, только я не умею такое делать, есть предложения.?