文件名称:gravity-adapter-debezium:用于debezium的重力适配器
文件大小:15KB
文件格式:ZIP
更新时间:2024-04-20 12:06:02
Go
重力适配器 用于debezium CDC框架的重力适配器。 故障排除 快照不起作用 Debezium具有实现称为快照的初始负载的实现,但是适配器启动时以某种方式快照不起作用。 此问题的根本原因是该主题已存在或使用者组的偏移量不为零。 这意味着您过去可能已启动适配器。 解决方案是删除现有的使用者组和主题。 为了解决此问题,您可以在下面使用kafka命令: # Delete specific topic for datasource table in PostgreSQL kafka-topics --delete --bootstrap-server localhost:29092 --topic postgres_0.public.datasource # Delete consumer group for gravity adapter kafka-consumer-groups -
【文件预览】:
gravity-adapter-debezium-main
----pkg()
--------debezium-connector()
--------kafka-connector()
--------app()
--------adapter()
----cmd()
--------gravity-adapter-debezium()
----LICENSE(1KB)
----configs()
--------config.toml(74B)
----settings()
--------sources.json(808B)
----.gitignore(269B)
----README.md(866B)
----go.mod(591B)