14.2. 使用带有 Debezium 连接器的自定义转换器

先决条件

• 您有一个自定义转换器 Java 程序。

流程

• 要将自定义转换器与 Debezium 连接器搭配使用，请将 Java 项目导出到 JAR 文件，并将文件复制到包含您要使用它的每个 Debezium 连接器的 JAR 文件的目录中。
  
  例如，在典型的部署中，Debezium 连接器文件存储在 Kafka Connect 目录的子目录中(/kafka/connect)，每个连接器 JAR 在其自己的子目录中(/kafka/connect/debezium-connector-db2、 /kafka/connect/debezium-connector-mysql 等)。要将转换器与连接器搭配使用，请将转换器 JAR 文件添加到连接器的子目录中。

流程

• 通过在连接器配置中添加以下强制属性，为连接器实例启用转换器：

  converters: <converterSymbolicName> 

  1

  
  <converterSymbolicName>.type: <fullyQualifiedConverterClassName> 

  2

  Copy to Clipboard Toggle word wrap

  1

  converters 属性是必需的，枚举一个以逗号分隔的、用来与连接器一起使用的转换器实例的符号链接名称列表。在您为转换器指定的其他属性名称中，为此属性列出的值充当前缀。

  2

  & lt;converterSymbolicName > .type 属性是必需的，并指定实现转换器的类名称。例如，对于以前的 自定义转换器 示例，您可以在连接器配置中添加以下属性：

  converters: isbn
  isbn.type: io.debezium.test.IsbnConverter

  Copy to Clipboard Toggle word wrap

• 要将其他属性与自定义转换器关联，请为属性名称加上转换器的符号名称作为前缀，后跟一个点(.)。符号名称是您指定为 converters 属性的值的标签。例如，要为前面的 isbn converter 添加属性，以指定要传递给转换器代码中配置方法的 schema.name，请添加以下属性：

  isbn.schema.name: io.debezium.postgresql.type.Isbn

  Copy to Clipboard Toggle word wrap