replacefield transform是否仅用于替换或屏蔽字段名，或者是否可以使用静态值来更改字段的值？我的需要是在发布到kafka主题之前连接两个字段的值。
jslywgbw1#
org.apache.kafka.connect.transforms.InsertField 用于添加静态值或主题元数据（主题名称、分区、时间戳、偏移量等），但不连接或使用表达式。 org.apache.kafka.connect.transforms.ReplaceField 用于重命名/筛选现有字段，而不是添加新字段。也就是说，你必须创造你自己的 Transformation 可以合并字段列表的子类。或者发布现有的“原始”数据，然后使用kafka streams或ksql创建“丰富的”主题。
org.apache.kafka.connect.transforms.InsertField
org.apache.kafka.connect.transforms.ReplaceField
Transformation
1条答案
按热度按时间jslywgbw1#
org.apache.kafka.connect.transforms.InsertField用于添加静态值或主题元数据（主题名称、分区、时间戳、偏移量等），但不连接或使用表达式。org.apache.kafka.connect.transforms.ReplaceField用于重命名/筛选现有字段，而不是添加新字段。也就是说，你必须创造你自己的
Transformation可以合并字段列表的子类。或者发布现有的“原始”数据，然后使用kafka streams或ksql创建“丰富的”主题。