知识库

Neo4j Streams - Kafka 集成 - 故障排除必须收集清单

排除 Neo4j Streams 问题时，请使用下面的必须收集信息列表来协助调查。

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

    1. Neo4j Streams Source

    2. Neo4j Streams Sink

    3. Neo4j Streams Procedure

    4. Kafka Connect Sink。如果使用 Sink，请同时提供所选的数据格式（JSON 或 AVRO）。

  2. 插件配置列表

    • 如果使用 Neo4j Streams，请提供用于在 neo4j.conf 文件中配置 sink 的属性列表

    • 如果使用 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 指标

    • Broker 指标

    • Producer 指标

    • Consumer 指标

    • 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/

© . All rights reserved.