如何在Debezium上创建临时快照



我在一个容器中有Debezium,用于捕获PostgeSQL数据库记录的所有更改。

如何删除所有已经创建的kafka主题,并从一开始为所有配置的表启动特别快照?

您可以像使用任何其他主题一样使用kafka-topics --delete。Debezium通常与您的数据库模式/表名称相匹配。您还需要找到由KafkaConnect框架创建的内部偏移主题。

不过,对于Docker来说,如果你重新启动Kafka和Zookeeper,而它们没有附加卷,那么它们就会失去一切,这对于临时开发来说会更容易。

此外,您不再需要Zookeeper,从Kafka 3.3.1 开始

最新更新