我试图连接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的。
暂无答案!
目前还没有任何答案,快来回答吧!