SetSchemaMetadata用于键和值

谜2684

我正在使用Kafka Connect JDBC Source Connector将数据从Postgres数据库流式传输到Kafka。kafka群集中的所有消息都是由架构注册表管理的Avro消息。我想显式设置消息的键和值的架构名称。

我设法通过使用SetSchemaMetadata配置上的选项来实现键或值。

为设置值的架构名称，我正在使用：

"transforms": "SetSchemaMetadata",
"transforms.SetSchemaMetadata.type": 
"org.apache.kafka.connect.transforms.SetSchemaMetadata$Value",
"transforms.SetSchemaMetadata.schema.name": "myCustomValueSchemaName"

对于密钥，我正在使用：

"transforms": "SetSchemaMetadata",
"transforms.SetSchemaMetadata.type": 
"org.apache.kafka.connect.transforms.SetSchemaMetadata$Key",
"transforms.SetSchemaMetadata.schema.name": "myCustomKeySchemaName"

有没有办法在连接配置上设置它们两者？

非常感谢

伊斯库斯科夫·亚历山大（Iskuskov Alexander）

我认为您可以使用链式转换：

"transforms": "KeySchemaMetadata,ValueSchemaMetadata",

"transforms.KeySchemaMetadata.type": "org.apache.kafka.connect.transforms.SetSchemaMetadata$Key",
"transforms.KeySchemaMetadata.schema.name": "myCustomKeySchemaName",

"transforms.ValueSchemaMetadata.type": "org.apache.kafka.connect.transforms.SetSchemaMetadata$Value",
"transforms.ValueSchemaMetadata.schema.name": "myCustomValueSchemaName"

本文收集自互联网，转载请注明来源。

如有侵权，请联系 [email protected] 删除。