Kafka Connect SMT -扁平消息

Question

我有一条卡夫卡的信息，如下所示。

{
   “prop1”: “val1”,
   “prop2”: “val2”,
   “sub_msg”: {
       “prop3”: “val3”,
       “prop4”: “val4”,
    },
   “prop5”: “val5”
}

我要把它压平。就像下面这样。

{
   “prop1”: “val1”,
   “prop2”: “val2”,
   “prop3”: “val3”,
   “prop4”: “val4”,
   “prop5”: “val5”
}

我看的是能够在平面结构中替换字段名的ReplaceField SMT。

我的问题是-这个SMT也能处理嵌套结构吗？或者-是否有一个“扁平化”的SMT可用的盒子？

编辑(1)

我可以看到压扁 SMT，但它添加了嵌套对象的“路径”--如果我可以禁用“路径”连接--它可以为我工作。无论如何，我看不出在文档中禁用它。

编辑(2)

我目前的方向是扩展扁平化器，使其不可能连接字段名。

新的配置字段：

1. concatenate.field.names /布尔值默认: true
2. duplicate.field.strategy \ Enum (FirstSeenWins，LastSeenWins) _

使用上面的两个配置属性，一个可以设置有关字段名的SMT行为，连接和控制在重复的情况下应该发生的事情。

Answer 1

ReplaceField只能在顶级字段上使用.

您需要将平面转换与重命名转换组合起来，以便能够删除sub_msg前缀。