Я использую Java Spring для построения конвейера данных (Kafka -> Spark -> MongoDB). Пользователь может изменить формат необработанных данных (или добавить новый поток данных). В таком случае, есть ли способ добавить соответствующее правило преобразования динамически (или на лету)? Спасибо!