我正在运行一个到PostgreSQL的Debezium连接器。我使用的snapshot.mode是initial，因为我不想仅仅因为连接器已重新启动就重新快照。然而，在开发过程中，我想重新启动这个过程，因为Kafka的消息在读取之前就过期了。
如果我通过Kafka Connect REST API删除并重新创建连接器，这不会起到任何作用，因为offset/status/config主题中的信息会被保留。当重新启动整个连接集群以触发另一个快照时，我必须删除并重新创建它们。
我是不是错过了一种更方便的方法？
您还需要连接器的新名称以及连接器配置中的新database.server.name名称，该名称存储所有偏移信息。这应该就像是第一次再次部署连接器一样。
答案可能晚了，但我也有这个要求。张贴它是为了将来帮助别人。
我配置了"；snapshot.mode"；作为"；总是"；在dabezium-postgres.json文件中。因此，每当我删除并添加这个dabezium连接器(分别通过DELETE和POSTREST API(时，它都会触发带有READ事件的完整快照。这里kafka连接服务器没有重新启动。我的应用程序(kafkaconsumer(可以重新进入这些事件并对其进行处理。