# Neo4j的Apache kafka连接器

Kafka Connect 是 Apache Kafka 的开源组件，是一个框架，用于将 Kafka 与外部系统（例如数据库、键值存储、搜索索引和文件系统）连接起来。

Neo4j Streams 项目提供了一个 Kafka Connect Neo4j 连接器，它可以安装到 Confluent 平台中，从而实现：

- 通过模板化的 Cypher 查询将来自 Kafka 主题的数据直接摄取到 Neo4j 中；
- 流式处理 Neo4j 查询。

Neo4j Streams 将 Neo4j 与 Apache Kafka 事件流集成在一起，用作数据源，例如更改数据 (CDC) 或接收器以将任何类型的 Kafka 事件摄取到您的图形中。

Kafka Connect Neo4j Sink 插件将与 Confluent Cloud 以及大多数形式的 Apache Kafka 一起使用，包括使用单独的 Connect 框架和基础设施在本地运行。建议需要数据接收器功能的人使用此方法。

企业用户可以在他们现有的支持协议下使用 Neo4j Streams。Neo4j 社区用户也可以在社区支持下使用 Neo4j Streams。

- [Kafka Connect：Neo4j 源插件](https://neo4j.com/docs/labs/neo4j-streams/current/#_kafka_connect)（[Confluent Hub](https://www.confluent.io/connector/kafka-connect-neo4j-sink/)）
- [Neo4j 插件：更改数据源](https://neo4j.com/docs/labs/neo4j-streams/current/#_neo4j_streams_producer)
- [Neo4j 插件：接收器](https://neo4j.com/docs/labs/neo4j-streams/current/#_neo4j_streams_consumer)
- [Neo4j 插件：程序](https://neo4j.com/docs/labs/neo4j-streams/current/#_procedures)
- [Docker Compose 设置](https://neo4j.com/docs/labs/neo4j-streams/current/#docker)

![](https://neo4j.com/labs/kafka/_images/kafka-source-flow.png)

问题：

下列描述中哪一个是不正确的？

## 答案

Kafka连接器只能与Confluent平台一起使用

## 选项

### A

不需要同时配置Neo4j插件和Kafka Connect工作线程

### B

作为**Neo4j 插件**，neo4j-streams 运行在数据库内部，可以消费和生成消息到 Kafka。

### C

一个挑战是将Kafka中的消息转换成图数据模型，然后加载到Neo4j中

### D

Kafka连接器只能与Confluent平台一起使用