【发布时间】:2022-10-25 15:12:05
【问题描述】:
我正在运行一个到 PostgreSQL 的 Debezium 连接器。我使用的snapshot.mode 是initial,因为我不想仅仅因为连接器已重新启动而重新快照。但是,在开发过程中,我想重新启动该过程,因为消息在被读取之前从 Kafka 过期。
如果我通过 Kafka Connect REST API 删除并重新创建连接器,这不会做任何事情,因为 offset/status/config 主题中的信息会被保留。重新启动整个连接集群以触发另一个快照时,我必须删除并重新创建它们。
我错过了一种更方便的方法吗?
【问题讨论】:
标签: apache-kafka-connect debezium