从 5.0 升级到 5.1

在将 Neo4j Kafka 连接器升级到 5.1 时,请注意许多配置属性已被更改和更新。请阅读 最新动态 以了解最近的更改,并确保新的配置在逻辑上与之前的配置相匹配。

有关通用 Kafka Connect 插件升级的文档,请参见: Confluent 文档 → 升级连接器插件

在遵循迁移指南之前,连接器必须在 5.0.6 版本,因为该版本包含配置转换助手,可简化升级过程。

迁移指南

按照相关说明配置并部署新连接器。

故障排除

  1. 无法连接到 Neo4j 实例?

    配置迁移过程不会迁移 Neo4j 实例的密码或其他敏感属性。您需要重新输入这些属性。更新后,重新启动连接器。

  2. 意外错误

    查看 Kafka Connect 的日志可能会显示配置中的其他错误。

    1. 在 Confluent Cloud 上,可通过连接器运行页面的日志部分访问日志。

    2. 在 Confluent Platform 上,可通过 Docker 命令docker-compose logs -f connect访问日志。