Kafka Connect with MSSQL不适用于删除操作

Question

我在SQL Server 2014上使用Kafka Connect和Confluent MSSQL connector。我尝试了插入和更新操作，它们工作正常，将正确的记录推送到Kafka。如果我删除了一条记录，我会收到以下关于Kafka主题的消息:

{"schema":null,"payload":null}

相反，我希望删除记录的详细信息。

我使用以下命令启用CDC：

ALTER DATABASE WebAppDb SET CHANGE_TRACKING = ON (CHANGE_RETENTION = 2 DAYS, AUTO_CLEANUP = ON) 
GO 
ALTER DATABASE WebAppDb SET ALLOW_SNAPSHOT_ISOLATION ON 
GO 
ALTER TABLE dbo.Users ENABLE CHANGE_TRACKING WITH (TRACK_COLUMNS_UPDATED = ON)
GO

Answer 1

这实际上代表一条删除消息，如果您的有效负载为空，这意味着记录已被删除，您现在可以做的是检查消息key并在您的消费者中进行所需的删除。

您现在看到的有效负载确实是错误的，Kafka Connect中有一个错误，它无法阻止Json转换以生成＜code＞tombstone

{"schema":null,"payload":null}

当错误修复发布时，您的消息应该有一个null正文，但在这两种情况下，您可以对删除采取相同的方式。

有关该错误的更多信息，请单击此处

有关逻辑删除消息的更多信息，请单击此处

Answer 2

我会检查连接器和MSSQL服务器版本在使用中，因为根据合流网站为Kafka连接微软SQL服务器连接器

变更数据捕获是仅在SQL Server企业版和开发人员版上提供的功能

然后检查这个问题的答案和Debezium Connector forSQLServer的信息。
看起来这个问题可能仍然需要实现，因为它仍然在Github上打开