知识库

Neo4j Streams - Kafka 集成 - 故障排除必备信息

在对 Neo4j Streams 问题进行故障排除时，请使用以下必备信息清单来帮助调查。

  1. 您使用的是哪个插件/模块？

    1. Neo4j Streams 源

    2. Neo4j Streams 接收器

    3. Neo4j Streams 过程

    4. Kafka Connect 接收器。如果您使用接收器，请同时提供所选数据格式 (JSON 或 AVRO)。

  2. 插件配置列表

    • 如果您使用 Neo4j Streams，请提供用于将接收器配置到 neo4j.conf 文件中的属性列表

    • 如果您使用 Kafka Connect，请提供用于在 Kafka Connect 框架中创建插件实例的 *.json 或 *.properties 文件

  3. Apache Kafka 版本

    • 转到 Apache Kafka 或 Confluent Platform（取决于您使用的发行版）安装文件夹，然后进入 /bin 文件夹。运行以下命令并提供输出：./kafka-configs.sh --version

  4. 提供 Neo4j/Kafka Connect 调试日志：如果您使用 Neo4j 插件，我们需要 neo4j.log 文件，否则需要 Kafka Connect 日志文件。Kafka Connect 日志文件位于 <kafka_connect_home>/logs/connectDistributed.out 文件夹下

  5. Kafka 配置

    • 用于实例化 Kafka 集群配置的配置

  6. (可选) Kafka 指标

    • 代理指标

    • 生产者指标

    • 消费者指标

    • Zookeeper 指标

    • 默认情况下，指标日志位于 server.log 文件中

  7. (可选) Neo4j 指标

    • CSV 文件

参考

Neo4j 流数据集成用户指南 https://neo4j.ac.cn/docs/labs/neo4j-streams/current/

Neo4j 指标输出工具 https://neo4j.ac.cn/docs/operations-manual/current/monitoring/metrics/