spring kafka项目的debezium发件箱错误

kpbpu008  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(458)

我试图连接2个微服务使用Kafka连接器在 Spring 使用docker容器。
有关项目详细信息,请参阅此gitlab链接。
Spring我有两个集装箱。
s1抵押服务
s1捐助服务
首先,我需要运行s1认捐服务(通过 startup.sh 在相应的项目文件夹),它可以正常工作。
其次,我运行第二步,运行s1 donorservice(通过 startup.sh 在相应的项目文件夹中),它可以正常工作。
第三,当我跑步的时候 ./register_connectors.sh 在s1 reservice中,出现以下错误:

{
  "error_code": 400,
  "message": "Connector configuration is invalid and contains the following 2 error(s):
         \nInvalid value io.debezium.transforms.Filter for configuration transforms.outbox.type: Class io.debezium.transforms.Filter could not be found.
         \nInvalid value null for configuration transforms.outbox.type: Not a Transformation\nYou can also find the above list of errors at the endpoint `/connector-plugins/{connectorType}/config/validate`"
}

运行服务会出现以下异常:

kafka-connect    | 2020-12-23 08:16:43,906 ERROR  ||  Uncaught exception in REST call to /connectors/   [org.apache.kafka.connect.runtime.rest.errors.ConnectExceptionMapper]
kafka-connect    | javax.ws.rs.NotAllowedException: HTTP 405 Method Not Allowed

是否需要debezium filter pom.xml依赖关系?
注意,我是从wsl2中的debian发行版运行docker的。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题