Debezium，Kafka-connect :对帖子的更新不会显示为消息，只有插入

Question

我正在使用命令： # bin/connect-standalone.sh config/connect-standalone.properties config/debezium-config.properties

我的debezium-config.properties是：

name=publications-connector
database.hostname=localhost
database.port=5432
database.user=andy
database.password=postgres
database.dbname=postgres
database.server.name=dbserver1
table.whitelist=public.publications

在Postgres中，我有一个名为出版物的表

当我在发布表中插入新记录时，我可以看到我的使用者以 json 格式显示新消息。

但是，当我将现有记录更新到出版物中时，不会向该主题发布任何新消息，因此无需使用任何内容。

我该如何解决这个问题？

另外，我想在我的数据库中添加另一个表"注释"。我需要对 debezium-config.properties 文件或其他任何地方进行哪些更改才能将这些消息发布到其自己的主题中？

我从控制台看到以下日志： WARN：在"source_info[服务器=dbserver1"db='postgres'的更新消息中找不到表"public.publications"的值，....架构=公共，表=发布]';skipping record (io.debezium.connector.postgres.RecordsStreamProducer：333)

谢谢

Answer 1

在详细阅读了许多debezium主题之后，我能够通过将REPLICA IDENTITY设置为FULL来解决这个问题。完成此操作后，在更新时，我能够看到更新消息并使用它们。

Answer 2

我认为原因是这样的： 如果表没有主键，连接器不会为该表发出 UPDATE 或 DELETE 事件。对于没有主键的表，连接器仅发出创建事件。通常，没有主键的表用于将消息追加到表的末尾，这意味着 UPDATE 和 DELETE 事件没有用处。 参考资源