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

先决条件

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

流程

• 要将自定义转换器与 Debezium 连接器搭配使用，请将 Java 项目导出到 JAR 文件，并将文件复制到包含您要与之搭配使用的每个 Debezium 连接器的 JAR 文件的目录中。
  
  例如，在典型的部署中，Debezium 连接器文件存储在 Kafka Connect 目录的子目录中(/kafka/connect)，每个连接器 JAR 位于其自己的子目录中(/kafka/connect/debezium-connector-db 2、/kafka/connect/debezium-mysql 等)。要将转换器与连接器搭配使用，请将 converter 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 添加属性，以指定要传递给转换器代码中的 configure 方法的 schema.name，请添加以下属性：

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

  Copy to Clipboard Toggle word wrap