ребят, есть вопрос по кафке. у меня есть пара методов (лисенеров), которые принимают наследников класса BaseRequest. все это дело должно сериализоваться/десериализоваться в json. проблема в том, что на клиенте кафка не может сконвертить json из родительского класса в дочерний. может кто нить знает, как это правильно настроить?
У нас данные из кафки вливаются в clickhouse для аналитики, а там дедупликация через ReplacingMergeTree. На стыке кафки и внешнего мира, как ни крути, боль, страдания и дубликаты.