在融合的 kafka 连接容器中配置 debezium 基于内容的路由

Question

我使用 kafka connect 将数据库从 postgres db 复制到 mongo db。我按照docs配置基于内容的路由。当我调用 api 将源连接器注册到 kafka 连接时，它会抛出异常：

java.lang.ClassNotFoundException: io.debezium.DebeziumException

。

是否可以在融合的 kafka 连接容器中使用 debezium 基于内容的路由？

Answer 1

可以在融合的 kafka 连接容器中使用 debezium 基于内容的路由

如果不将 Debezium JAR 文件添加到容器的 CLASSPATH 上，就不行。默认情况下，这些镜像没有安装 Debezium（或 MongoDB）代码。