Kafka connect transforms (SMT) - 帮助解决用例

Question

我有一个用例，我想使用 kafka 源或接收器连接器将我的源 table 关键字段映射到目标 table 参考字段。

我是这个论坛的新手，如果我缺少任何信息，请告诉我。提前致谢！

Answer 1

您应该使用：org.apache.kafka.connect.transforms.ReplaceField$Value 转换

带有转换的配置部分应该如下所示：

{
    ...
    "transforms": "RenameField",
    "transforms.RenameField.type": "org.apache.kafka.connect.transforms.ReplaceField$Value",
    "transforms.RenameField.renames": "SRC_ID:SRC_REF_ID"
    ...
}

如果您的列 SRC_ID 是 Int 类型，您可能还需要转换为 String。为此，您可以使用：org.apache.kafka.connect.transforms.Cast

可以找到有关默认转换的更多详细信息：https://kafka.apache.org/documentation/#connect_transforms

Kafka connect transforms (SMT) - 帮助解决用例

Kafka connect transforms (SMT) - Help to resolve the use case

apache-kafka

apache-kafka-connect