У меня есть данные JSON в виде строки в теме, и я хотел бы использовать и обновить значение для нескольких полей на основе определенной логики, а затем перенести их в другую тему. Здесь мы пытаемся сделать его управляемым свойством / базой данных для обновляемых полей и используемой логики.
Я мог бы использовать Groovy-скрипт для определения логики и сохранить его в БД и использовать его в потоковом режиме. Есть ли другой лучший способ / подход с Kafka Streaming DSL?