当我用debezium+kafka+postgres+elasticsearch做cdc时，我需要转换一个列。
在elasticsearch中，我有一个关于这个json的例子：

{"name": "Julia", "store":"Americanas"}

移动到postgres，我想将我的存储数据转换为：

{"name":"Julia", "store":"WallMart"}

我该怎么做？
在我的搜索中，我发现了smt，但我没有找到谁smt我可以申请做这个更新。我发现了spark、ksql和alpakka的流处理，但我不知道它们是否能解决我的问题。