知识库

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 指标

    • Broker(代理)指标

    • Producer(生产者)指标

    • Consumer(消费者)指标

    • Zookeeper(ZooKeeper)指标

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

  7. (可选) Neo4j 指标

    • CSV 文件

参考

Neo4j 流式数据集成用户指南 /docs/labs/neo4j-streams/current/

© . This site is unofficial and not affiliated with Neo4j, Inc.