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

kmynzznz  于 2023-11-16  发布在  Apache
关注(0)|答案(1)|浏览(109)

我使用Kafka connect将数据库从postgres db复制到mongo db。我配置基于内容的路由遵循docs。当我调用API将源连接器注册到Kafka connect时,它抛出异常:java.lang.ClassNotFoundException: io.debezium.DebeziumException
可以在融合Kafka连接容器中使用debezium基于内容的路由吗?

k4emjkb1

k4emjkb11#

在融合Kafka连接容器中可能使用基于内容的debezium路由
如果不将Debezium镜像文件添加到container的CLASSPATH上,就不能。默认情况下,这些镜像没有安装Debezium(或MongoDB)代码。

相关问题