Spring Kafka项目的Debezium Outbox错误

Question

我正在尝试使用Docker容器在Spring中使用Kafka连接器连接2个微服务。

有关项目详细信息，请参阅此Gitlab链接。

我在春天有两个集装箱。

1. s1质押服务
2. s1不服务

首先，我需要运行s1质押服务(通过相应项目文件夹中的startup.sh(，它可以正常工作。

其次，我运行第二步，当我运行s1 donorservice(通过相应项目文件夹中的startup.sh(时，它运行得很好。

第三，当我在s1质押服务中运行./register_connectors.sh时，我得到以下错误：

{
"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 TransformationnYou can also find the above list of errors at the endpoint `/connector-plugins/{connectorType}/config/validate`"
}

运行s1质押服务会出现以下异常：

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。

Answer 1

在我看来，您使用的是Debezium 1.1.2，而您尝试使用的转换仅在1.2.x时添加。