使用Transform创建Debezium连接器时遇异常求助

问题核心 #

添加Filter Transform配置后触发java.lang.NoClassDefFoundError: io/debezium/config/EnumeratedValue错误，移除Transform配置后连接器可正常运行，说明是Transform相关依赖缺失或版本不兼容导致的类加载失败。

解决步骤 #

1. 严格匹配Debezium版本一致性 #

确保以下jar包的版本与你使用的Debezium连接器主版本完全一致（例如Debezium 2.2.0，则所有相关jar都必须是2.2.0版本）：

• debezium-scripting-<version>.jar
• groovy-<version>.jar
• groovy-jsr223-<version>.jar
• debezium-core-<version>.jar
• debezium-api-<version>.jar

版本不匹配是引发该类加载错误的最常见原因。

2. 放置jar包到正确的插件目录 #

不要仅将jar包放在/usr/share/java全局目录，需将所有相关依赖jar复制到对应Debezium连接器的插件目录下：

• 若使用MySQL连接器，目录通常为/usr/share/java/debezium-connector-mysql
• 若使用PostgreSQL连接器，目录通常为/usr/share/java/debezium-connector-postgres

Kafka Connect采用插件隔离加载机制，只有连接器插件目录下的jar才会被该连接器的类加载器识别。

3. 验证核心类存在性 #

执行以下命令确认EnumeratedValue类存在于核心jar中：

jar tf /path/to/debezium-core-<version>.jar | grep io/debezium/config/EnumeratedValue

若输出为空，说明你使用的debezium-core jar包不完整或版本错误，需重新下载对应版本的官方包。

4. 完全重启Kafka Connect服务 #

修改jar包后，必须停止并重新启动Kafka Connect分布式服务：

# 停止服务
sudo systemctl stop confluent-kafka-connect  # 替换为你的实际服务名
# 启动服务
sudo systemctl start confluent-kafka-connect

确保服务完全重启，避免旧的类加载缓存影响。

5. 检查Transform配置语法（可选） #

依赖问题解决后，确认Filter条件表达式的语法正确性：

"transforms.filter.condition": "value.op == 'u' && value.before.id == 1"

注意Groovy语法中逻辑与为&&，需确保字段名称与Debezium输出的事件结构一致。

内容的提问来源于stack exchange，提问作者Gordon Murray