基于debezium内容的路由配置

Question

我使用的是confluent，所以我已经根据confluent文档使用Connect.Properties中的confluent-hub安装了dibezium连接器

plugin.path=/usr/share/java,/opt/confluent-6.0.0/share/confluent-hub-components

我需要使用io.debezium.transforms.contentbasedrouter https://debezium.io/documentation/reference/1.3/configuration/content-based-routing.html

因此，根据debezium文档，我下载了debezium-scripting-1.3.1.final.jar并将其放入/opt/confluent-6.0.0/share/confluent-hub-components/并将其复制到/opt/confluent-6.0.0/share/confluent-hub-components/debezium-debezium-connector-sqlserver/lib目录中，这里是我的mysql_src.json连接器中的条目

"transforms": "unwrap,route",
"transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
"transforms.unwrap.add.fields": "source.snapshot",
"transforms.route.type": "io.debezium.transforms.ContentBasedRouter",
"transforms.route.language": "jsr223.groovy",
"transforms.route.topic.expression": "value.__source_snapshot == 'false' ? 'test'"

当我试图配置/加载此连接器时，我收到以下错误消息

[2020-12-15 22:18:45,351] ERROR [Worker clientId=connect-1, groupId=connect-cluster] Failed to reconfigure connector's tasks, retrying after backoff: (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1369)
java.lang.NoClassDefFoundError: io/debezium/DebeziumException

有什么建议如何解决这个问题？

Answer 1

根据这些文档，您需要另外获得一个JSR-223脚本引擎实现，并将其内容添加到Kafka Connect环境的Debezium插件目录中，因为：

Debezium没有附带JSR223 API的任何实现。要将表达式语言与Debezium一起使用，必须下载该语言的JSR223脚本引擎实现，并将该语言实现使用的任何其他JAR文件一起添加到Debezium连接器插件目录中。